Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spark-structured-streaming

Structured Streaming exception: Append output mode not supported for streaming aggregations

How to use a external trigger to stop structured streaming query?

Kafka Structured Streaming checkpoint

How pass Basic Authentication to Confluent Schema Registry?

How to change the location of _spark_metadata directory?

TypeError: 'Builder' object is not callable Spark structured streaming

Spark 2.3.0 Failed to find data source: kafka

Unable to find LoginModule class: org.apache.kafka.common.security.plain.PlainLoginModule

Spark Structured Streaming with Kafka - How to repartition the data and distribute the processing among worker nodes

Custom state store provider for Apache Spark on Mesos

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

Structured Streaming output is not showing on Jupyter Notebook

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