Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-spark

ClassNotFoundException anonfun when deploy scala code to Spark

Round Down Double in Spark

Where is the union() method on the Spark DataFrame class?

Dividing complex rows of dataframe to simple rows in Pyspark

What is the right way to edit spark-env.sh before running spark-shell?

Spark Scala: Task Not serializable error

scala apache-spark pyspark

pyspark py4j.Py4JException: Method and([class java.lang.Integer]) does not exist

Spark job is failed due to java.io.NotSerializableException: org.apache.spark.SparkContext

java scala hadoop apache-spark

Unable to submit jobs to spark cluster (cluster-mode)

Why does partition parameter of SparkContext.textFile not take effect?

scala apache-spark rdd

SBT cannot import Kafka encoder/decoder classes

How to limit decimal values to 2 digits before applying agg function?

Find column index by searching column header of a Dataset in Apache Spark Java

convert RDD to Dataset in Java Spark

java apache-spark

Spark Failure : Caused by: org.apache.spark.shuffle.FetchFailedException: Too large frame: 5454002341

Spark java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to java.util.ArrayList

How to fix 'Unsupported class file major version 55' while executing 'org.apache.spark.sql.DataSet.collectAsList()'

How to filter a Spark dataframe by a boolean column?

Can I read a CSV represented as a string into Apache Spark using spark-csv

Error: not found: value lit/when - spark scala