Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in apache-spark

How to process logs from distributed log broker (Eg Kafka) exactly after 1 week?

java python apache-spark apache-kafka apache-storm

spark-nlp : DocumentAssembler initializing failing with 'java.lang.NoClassDefFoundError: org/apache/spark/ml/util/MLWritable$class'

python apache-spark pyspark johnsnowlabs-spark-nlp

Why is Pandas UDF not being parallelized?

python apache-spark pyspark databricks azure-databricks

Get difference between two version of delta lake table

scala apache-spark delta-lake

Spark Structured Streaming program that reads from non-empty Kafka topic (starting from earliest) triggers batches locally, but not on EMR cluster

apache-spark apache-kafka amazon-emr spark-structured-streaming

saveAsTextFile to s3 on spark does not work, just hangs

amazon-s3 apache-spark

Apache Spark Native Libraries

hadoop 64-bit apache-spark hadoop-yarn

Drawbacks of Spark Streaming in Comparison With Real Streaming Computing Systems

distributed-computing apache-spark apache-storm

Multipart uploads to Amazon S3 from Apache Spark

file-upload amazon-s3 apache-spark jets3t

How can I make Spark Streaming count the words in a file in a unit test?

java unit-testing apache-spark spark-streaming

How do I use infinite Scala streams as source in Spark Streaming?

scala apache-spark spark-streaming

Spark MLLib Collaborative Filtering with new user

apache-spark apache-spark-mllib collaborative-filtering

Unable to add a new service with Cloudera Manager within Cloudera Quickstart VM 5.3.0

apache-spark cloudera cloudera-manager cloudera-quickstart-vm

How does partitions map to tasks in Spark?

apache-spark rdd

Spark 1.3.1: cannot read file from S3 bucket, org/jets3t/service/ServiceException

amazon-ec2 amazon-s3 apache-spark hadoop2

Apache Spark-Kafka.TaskCompletionListenerException & KafkaRDD$KafkaRDDIterator.close NPE on local cluster(Client Mode)

java hadoop apache-spark apache-kafka spark-streaming

parquet.io.ParquetDecodingException: Can not read value at 0 in block -1 in file

java hadoop apache-spark hive

Why does format("kafka") fail with "Failed to find data source: kafka." (even with uber-jar)?

apache-spark apache-spark-sql spark-structured-streaming uberjar

DataFrame error: "overloaded method value filter with alternatives"

scala apache-spark dataframe

ERROR Utils: Uncaught exception in thread SparkListenerBus

scala apache-spark
« Newer Entries Older Entries »