Some streams terminated before this command could finish! -> java.lang.NoClassDefFoundError: scala/c

PiotrU
Contributor II

‎11-02-2023 08:26 AM

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 ? 
0 Kudos

PiotrU
Contributor II

‎11-02-2023 08:49 AM

Of course just after writing that post I did realized how dummy this question is .... after adding scala_java8_compat_2_12_1_0_2.jar it works as expected

View solution in original post