spark-streaming tutorials

Spark Streaming Kafka - Job always quits when RDD contains an actual message

Jun 22, 2018

java spark-streaming apache-kafka

Spark Streaming Bug - Window of Windowed DStream does not work

Nov 19, 2022

apache-spark spark-streaming

Getting java.lang.IllegalArgumentException: requirement failed while calling Sparks MLLIB StreamingKMeans from java application

Mar 18, 2020

java apache-spark bigdata hadoop2 spark-streaming

Batch Size in Spark Streaming

Aug 30, 2022

scala twitter apache-spark twitter4j spark-streaming

Multiple windows of different durations in Spark Streaming application

May 24, 2018

apache-spark real-time analytics apache-kafka spark-streaming

Spark mapWithState shuffles all data to one node

Nov 06, 2022

scala apache-spark spark-streaming

Spark Streaming - processing binary data file

Aug 29, 2022

pyspark spark-streaming

How to convert RDD to DataFrame in Spark Streaming, not just Spark

Oct 18, 2022

scala apache-spark spark-streaming rdd

Spark-Streaming Kafka Direct Streaming API & Parallelism

Oct 17, 2022

apache-spark apache-kafka spark-streaming

Spark Streaming Guarantee Specific Start Window Time

May 09, 2022

scala apache-spark spark-streaming amazon-kinesis

Spark Structured Streaming Checkpoint Compatibility

Mar 26, 2022

apache-spark apache-kafka spark-streaming spark-structured-streaming

"java.io.IOException: Class not found" on long running Streaming application

Sep 03, 2021

apache-spark spark-streaming

Access files in resources directory in JAR from Apache Spark Streaming context

Oct 20, 2022

java apache-spark spark-streaming

Why does Kafka Direct Stream create a new decoder for every message?

Aug 26, 2022

java apache-spark apache-kafka spark-streaming kryo

Spark - Non-time-based windows are not supported on streaming DataFrames/Datasets;

Sep 14, 2022

java apache-spark apache-spark-sql spark-streaming

Will there be any scenario, where Spark RDD's fail to satisfy immutability.?

Oct 19, 2022

apache-spark spark-streaming rdd

spark streaming assertion failed: Failed to get records for spark-executor-a-group a-topic 7 244723248 after polling for 4096

Mar 17, 2022

apache-spark apache-kafka spark-streaming

How to convert bytes from Kafka to their original object?

Nov 07, 2021

apache-spark apache-kafka spark-streaming spark-avro

joins and cogroup in Spark

Sep 14, 2019

apache-spark spark-streaming

SparkStreaming - ExitCodeException exitCode=13

May 12, 2022

java apache-spark spark-streaming

New posts in spark-streaming