Query query-65 terminated with exception: null

      null 



=== Streaming Query ===
Name: query-65
Current Offsets: {KafkaSource[SubscribePattern[failOnDataLoss.*]]: {"failOnDataLoss-1":{"0":28},"failOnDataLoss-0":{"0":0},"failOnDataLoss-2":{"0":13}}}

Current State: TERMINATED
Thread State: TERMINATED

Logical Plan:
SerializeFromObject [input[0, int, true] AS value#5587]
+- MapElements <function1>, class scala.Tuple2, [StructField(_1,StringType,true), StructField(_2,StringType,true)], obj#5586: int
   +- DeserializeToObject newInstance(class scala.Tuple2), obj#5585: scala.Tuple2
      +- Project [cast(key#5561 as string) AS key#5576, cast(value#5562 as string) AS value#5577]
         +- StreamingExecutionRelation KafkaSource[SubscribePattern[failOnDataLoss.*]], [key#5561, value#5562, topic#5563, partition#5564, offset#5565L, timestamp#5566, timestampType#5567]


Error:
java.lang.NullPointerException

     
       
      at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runBatches(StreamExecution.scala:250)
      at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:144)
      Cause: java.lang.NullPointerException
      at