While running Qubole pipeline facing the following exception
App > java.lang.ClassCastException: com.qubole.spark.streaminglens.StreamingLens cannot be cast to scala.runtime.Nothing$
App > at scala.Option.foreach(Option.scala:407)
App > at org.apache.spark.sql.streaming.StreamingQueryManager.updateInsightManagerTrigger(StreamingQueryManager.scala:508)
App > at org.apache.spark.sql.streaming.StreamingQueryManager.startQuery(StreamingQueryManager.scala:489)
App > at org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:319)
What could be the possible reasons for it and what's the solution around it?
While running Qubole pipeline facing the following exception
App > java.lang.ClassCastException: com.qubole.spark.streaminglens.StreamingLens cannot be cast to scala.runtime.Nothing$ App > at scala.Option.foreach(Option.scala:407) App > at org.apache.spark.sql.streaming.StreamingQueryManager.updateInsightManagerTrigger(StreamingQueryManager.scala:508) App > at org.apache.spark.sql.streaming.StreamingQueryManager.startQuery(StreamingQueryManager.scala:489) App > at org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:319)
What could be the possible reasons for it and what's the solution around it?