https://community.databricks.com/t5/get-started-discussions/some-streams-terminated-before-this-command-could-finish-gt-java/m-p/50377#M6077 <P>Hello</P><P>I do face:</P><P><SPAN>Some streams terminated before this command could finish!</SPAN></P><P><SPAN>java.lang.NoClassDefFoundError: scala/compat/java8/FutureConverters$</SPAN></P><P><SPAN>Running some very simple query on eventhub :</SPAN></P><DIV><DIV><SPAN>df = spark \</SPAN></DIV><DIV><SPAN>.readStream \</SPAN></DIV><DIV><SPAN>.</SPAN><SPAN>format</SPAN><SPAN>(</SPAN><SPAN>"eventhubs"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.options(**ehConf) \</SPAN></DIV><DIV><SPAN>.load()</SPAN></DIV><BR /><DIV><SPAN>query = df \</SPAN></DIV><DIV><SPAN>.writeStream \</SPAN></DIV><DIV><SPAN>.outputMode(</SPAN><SPAN>"append"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.</SPAN><SPAN>format</SPAN><SPAN>(</SPAN><SPAN>"console"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.start()</SPAN></DIV><DIV>&nbsp;</DIV><DIV>My current setup is Runtime 13.3 LTS (Scala 2.12, Spark 3.4.1)</DIV><DIV><A>com.microsoft.azure:azure-eventhubs:3.2.2</A></DIV><DIV><SPAN>azure_eventhubs_spark_2_12_2_3_17.jar (manually installed)</SPAN></DIV><DIV><SPAN>I have tried different versions (mostly Runtime and eventhubs spark) - but it is still failing ...</SPAN></DIV><DIV><SPAN>Can someone point me to proper set-up of version to have that working ?&nbsp;</SPAN></DIV></DIV> Thu, 02 Nov 2023 15:26:12 GMT PiotrU 2023-11-02T15:26:12Z https://community.databricks.com/t5/get-started-discussions/some-streams-terminated-before-this-command-could-finish-gt-java/m-p/50377#M6077 <P>Hello</P><P>I do face:</P><P><SPAN>Some streams terminated before this command could finish!</SPAN></P><P><SPAN>java.lang.NoClassDefFoundError: scala/compat/java8/FutureConverters$</SPAN></P><P><SPAN>Running some very simple query on eventhub :</SPAN></P><DIV><DIV><SPAN>df = spark \</SPAN></DIV><DIV><SPAN>.readStream \</SPAN></DIV><DIV><SPAN>.</SPAN><SPAN>format</SPAN><SPAN>(</SPAN><SPAN>"eventhubs"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.options(**ehConf) \</SPAN></DIV><DIV><SPAN>.load()</SPAN></DIV><BR /><DIV><SPAN>query = df \</SPAN></DIV><DIV><SPAN>.writeStream \</SPAN></DIV><DIV><SPAN>.outputMode(</SPAN><SPAN>"append"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.</SPAN><SPAN>format</SPAN><SPAN>(</SPAN><SPAN>"console"</SPAN><SPAN>) \</SPAN></DIV><DIV><SPAN>.start()</SPAN></DIV><DIV>&nbsp;</DIV><DIV>My current setup is Runtime 13.3 LTS (Scala 2.12, Spark 3.4.1)</DIV><DIV><A>com.microsoft.azure:azure-eventhubs:3.2.2</A></DIV><DIV><SPAN>azure_eventhubs_spark_2_12_2_3_17.jar (manually installed)</SPAN></DIV><DIV><SPAN>I have tried different versions (mostly Runtime and eventhubs spark) - but it is still failing ...</SPAN></DIV><DIV><SPAN>Can someone point me to proper set-up of version to have that working ?&nbsp;</SPAN></DIV></DIV> Thu, 02 Nov 2023 15:26:12 GMT https://community.databricks.com/t5/get-started-discussions/some-streams-terminated-before-this-command-could-finish-gt-java/m-p/50377#M6077 PiotrU 2023-11-02T15:26:12Z https://community.databricks.com/t5/get-started-discussions/some-streams-terminated-before-this-command-could-finish-gt-java/m-p/50378#M6078 <P>Of course just after writing that post I did realized how dummy this question is .... after adding&nbsp;<A>scala_java8_compat_2_12_1_0_2.jar&nbsp;</A>it works as expected</P> Thu, 02 Nov 2023 15:49:27 GMT https://community.databricks.com/t5/get-started-discussions/some-streams-terminated-before-this-command-could-finish-gt-java/m-p/50378#M6078 PiotrU 2023-11-02T15:49:27Z