StackOverflow Questions for Tag: apache-spark-1.6

CodeDreamer

Reputation: 444

How to unit test Spark Streaming code?

apache-sparkspark-streamingapache-spark-1.6

Score: 1

Answers: 1

Jorge Cespedes

Reputation: 597

Spark Streaming 1.6 + Kafka: Too many batches in "queued" status

scalaapache-kafkaspark-streamingapache-spark-1.6

Score: 1

Answers: 1

Mnav505

Reputation: 13

Spark 1.6 - Overwrite directory with avro files failing using dataframes

apache-spark-sqlspark-avroapache-spark-1.6

Score: 1

Answers: 0

Naveen Yadav

Reputation: 9

How to drop duplicates considering only subset of columns?

scalaapache-spark-sqlapache-spark-1.6

Score: 0

Answers: 1

Alexvonrass

Reputation: 330

How to replace nulls in Vector column?

scalaapache-sparkapache-spark-sqlapache-spark-1.6

Score: 3

Answers: 2

Suresh Sethuramaswamy

Reputation: 31

pyspark memory issue :Caused by: java.lang.OutOfMemoryError: Java heap space

pysparkout-of-memoryapache-spark-1.6

Score: 2

Answers: 1

Ani Menon

Reputation: 28277

How to define partitions to Dataframe in pyspark?

dataframepysparkdata-partitioningapache-spark-1.6

Score: 0

Answers: 0

reapasisow

Reputation: 275

What to do with "WARN TaskSetManager: Stage contains a task of very large size"?

apache-sparkapache-spark-1.6

Score: 14

Answers: 1

Mercury Trivival

Reputation: 11

Error accessing Spark thrift Server

hadoopapache-sparkapache-spark-1.6spark-thriftserver

Score: 0

Answers: 2

Ahmet DAL

Reputation: 4700

Why Spark application on YARN fails with FetchFailedException due to Connection refused?

apache-sparkhadoop-yarnapache-spark-1.6

Score: 9

Answers: 2

prateek

Reputation: 1

Not able to load hive table into Spark

scalaapache-spark-sqlapache-spark-1.6

Score: 0

Answers: 1

summerbulb

Reputation: 5879

Spark temp tables not found

apache-sparkpysparkapache-spark-1.6hive-metastore

Score: 2

Answers: 0

Joseratts

Reputation: 97

How to know which is the RDD type inferred by Spark using Scala

scalashellapache-sparkrddapache-spark-1.6

Score: 0

Answers: 1

Mia21

Reputation: 119

Pyspark: How to return a tuple list of existing non null columns as one of the column values in dataframe

apache-sparkpysparkapache-spark-sqlapache-spark-1.6

Score: 2

Answers: 3

RudyVerboven

Reputation: 1274

Specify default value for rowsBetween and rangeBetween in Spark

apache-sparkapache-spark-sqlapache-spark-1.6

Score: 1

Answers: 2

oracletohive

Reputation: 15

Oracle to Spark/Hive: how to convert use of "greatest" function to Spark 1.6 dataframe

apache-spark-1.6

Score: 1

Answers: 1

Sumit

Reputation: 1450

Programmatically specifying the schema in PySpark

pysparkapache-spark-1.6

Score: 1

Answers: 1

Mia21

Reputation: 119

Pyspark- handling exceptions and raising RuntimeError in pyspark dataframe

apache-sparkpysparkapache-spark-sqlapache-spark-1.6

Score: 0

Answers: 1

Srinivas Bandaru

Reputation: 321

How to use different Hive metastore for saveAsTable?

apache-sparkhivepysparkapache-spark-sqlapache-spark-1.6

Score: 2

Answers: 2

Mia21

Reputation: 119

flatMap doesn't preserve order when creating lists from pyspark dataframe columns

pythonapache-sparkpysparkapache-spark-sqlapache-spark-1.6

Score: 1

Answers: 2

PreviousPage 3Next

StackOverflow Questions for Tag: apache-spark-1.6

How to unit test Spark Streaming code?

Spark Streaming 1.6 + Kafka: Too many batches in &quot;queued&quot; status

Spark 1.6 - Overwrite directory with avro files failing using dataframes

How to drop duplicates considering only subset of columns?

How to replace nulls in Vector column?

pyspark memory issue :Caused by: java.lang.OutOfMemoryError: Java heap space

How to define partitions to Dataframe in pyspark?

What to do with &quot;WARN TaskSetManager: Stage contains a task of very large size&quot;?

Error accessing Spark thrift Server

Why Spark application on YARN fails with FetchFailedException due to Connection refused?

Not able to load hive table into Spark

Spark temp tables not found

How to know which is the RDD type inferred by Spark using Scala

Pyspark: How to return a tuple list of existing non null columns as one of the column values in dataframe

Specify default value for rowsBetween and rangeBetween in Spark

Oracle to Spark/Hive: how to convert use of &quot;greatest&quot; function to Spark 1.6 dataframe

Programmatically specifying the schema in PySpark

Pyspark- handling exceptions and raising RuntimeError in pyspark dataframe

How to use different Hive metastore for saveAsTable?

flatMap doesn&#39;t preserve order when creating lists from pyspark dataframe columns

Spark Streaming 1.6 + Kafka: Too many batches in "queued" status

What to do with "WARN TaskSetManager: Stage contains a task of very large size"?

Oracle to Spark/Hive: how to convert use of "greatest" function to Spark 1.6 dataframe

flatMap doesn't preserve order when creating lists from pyspark dataframe columns