Query query-63 terminated with exception: null

      null 



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

Current State: TERMINATED
Thread State: TERMINATED

Logical Plan:
SerializeFromObject [input[0, int, true] AS value#5595]
+- MapElements <function1>, class scala.Tuple2, [StructField(_1,StringType,true), StructField(_2,StringType,true)], obj#5594: int
   +- DeserializeToObject newInstance(class scala.Tuple2), obj#5593: scala.Tuple2
      +- Project [cast(key#5569 as string) AS key#5584, cast(value#5570 as string) AS value#5585]
         +- StreamingExecutionRelation KafkaSource[SubscribePattern[failOnDataLoss.*]], [key#5569, value#5570, topic#5571, partition#5572, offset#5573L, timestamp#5574, timestampType#5575]


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