spark-streaming

275 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Spark Structured streaming getting incorrect number of input rows when using StreamingQueryListener QueryProgressEvent
user_148077080
•
2
1
547
spark-streaming spark-structured-streaming apache-spark
Spark: Exception in thread "main" java.util.ServiceConfigurationError: org.apache.spark.scheduler.ExternalClusterManager
user_30888970
•
2
0
253
spark-streaming apache-spark scala
Stream-Static Join: How to refresh (unpersist/persist) static Dataframe periodically
user_120945660
•
5
1
2097
spark-streaming spark-structured-streaming apache-spark-sql apache-spark scala
How to join spark rdd using between join?
user_85022640
•
2
0
20
spark-streaming
Spark multi-stage mapWithState Shuffle issue
user_9777990
•
2
0
59
spark-streaming apache-spark-sql apache-spark hadoop stream
PySpark - Create a pyspark dataframe using Kakfa Json message
user_94657100
•
1
1
322
spark-streaming apache-kafka-streams pyspark apache-spark
Error Stream metadata using Pyspark in Windows 10 OS
user_88289480
•
3
0
155
spark-streaming pyspark twitter python
Structured streaming output - compacting with OPTIMIZE without breaking outgoing read stream order guarantees
user_6902040
•
2
1
696
delta-lake spark-streaming databricks apache-spark
Stream from kafka to kafka with Spark Structured Streaming in scala
user_145248760
•
2
0
82
spark-streaming apache-spark scala
Use single streaming DataFrame for multiple output streams in PySpark Structured Streaming
user_96089450
•
3
2
780
spark-streaming spark-structured-streaming pyspark apache-spark
Hot Questions