This is a mistake in the code snippet I posted.
The right code that is actually running and producing the error is:
/ df = spark \
.readStream \
.format("kafka") \
.option("kafka.bootstrap.servers", "kafka_broker") \
.option("subscribe", "test_hdfs3") \
.load() \
.select(from_json(col("value").cast("string"), schema)/
--
Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/
---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
