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

New posts in spark-streaming

Spark Streaming: foreachRDD update my mongo RDD

mongodb apache-spark spark-streaming

Spark Streaming mapWithState seems to rebuild complete state periodically

scala apache-spark spark-streaming

How to fix "java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord" in Spark Streaming Kafka Consumer?

apache-spark serialization apache-kafka spark-streaming

What is the correct way to start/stop spark streaming jobs in yarn?

hadoop apache-spark spark-streaming hadoop-yarn cloudera

spark ssc.textFileStream is not streamining any files from directory

filesystems apache-spark spark-streaming data-stream

How to specify which java version to use in spark-submit command?

java hadoop-yarn spark-streaming

SBT Test Error: java.lang.NoSuchMethodError: net.jpountz.lz4.LZ4BlockInputStream

scala apache-spark sbt spark-streaming scalatest

Amazon s3a returns 400 Bad Request with Spark

amazon-web-services amazon-s3 apache-spark hdfs spark-streaming

Spark off heap memory leak on Yarn with Kafka direct stream

apache-spark spark-streaming hadoop-yarn apache-spark-1.4

How to create Spark RDD from an iterator?

apache-spark spark-streaming

Kafka topic partitions to Spark streaming

apache-spark apache-kafka spark-streaming

java.lang.NoClassDefFoundError: org/apache/spark/streaming/twitter/TwitterUtils$ while running TwitterPopularTags

scala maven apache-spark noclassdeffounderror spark-streaming

Spark Dataframe validating column names for parquet writes

apache-spark pyspark apache-spark-sql spark-streaming parquet

Spark streaming with Kafka - createDirectStream vs createStream

apache-spark apache-kafka spark-streaming

How to stop spark streaming when the data source has run out

python apache-spark apache-kafka pyspark spark-streaming

AbstractMethodError creating Kafka stream

scala apache-spark apache-kafka spark-streaming

Limit Kafka batches size when using Spark Streaming

apache-spark apache-kafka spark-streaming kafka-consumer-api

Spark Kafka Direct DStream - How many executors and RDD partitions in yarn-cluster mode if num-executors is set?

apache-spark apache-kafka spark-streaming

Condition in map function

scala apache-spark spark-streaming map-function

Why does starting StreamingContext fail with “IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute”?

java apache-spark spark-streaming
« Newer Entries Older Entries »