Hello
I do face:
Some streams terminated before this command could finish!
java.lang.NoClassDefFoundError: scala/compat/java8/FutureConverters$
Running some very simple query on eventhub :
df = spark \
.readStream \
.format("eventhubs") \
.options(**ehConf) \
.load()
query = df \
.writeStream \
.outputMode("append") \
.format("console") \
.start()
My current setup is Runtime 13.3 LTS (Scala 2.12, Spark 3.4.1)
azure_eventhubs_spark_2_12_2_3_17.jar (manually installed)
I have tried different versions (mostly Runtime and eventhubs spark) - but it is still failing ...
Can someone point me to proper set-up of version to have that working ?