<p>Query memory [id = cf247432-4a99-4333-8947-a81ecef088b5, runId = 4d081570-3381-4dde-8821-cc9d886763d9] terminated with exception: null</p>


<pre><code>
      org.apache.spark.sql.streaming.StreamingQueryException: null
=== Streaming Query ===
Identifier: memory [id = cf247432-4a99-4333-8947-a81ecef088b5, runId = 4d081570-3381-4dde-8821-cc9d886763d9]
Current Committed Offsets: {}
Current Available Offsets: {}

Current State: RECONFIGURING
Thread State: RUNNABLE

Logical Plan:
SerializeFromObject [input[0, int, false] AS value#2831]
+- MapElements org.apache.spark.sql.kafka010.KafkaSourceStressForDontFailOnDataLossSuite$$Lambda$4951/347906019@19a34d6f, class scala.Tuple2, [StructField(_1,StringType,true), StructField(_2,StringType,true)], obj#2830: int
   +- DeserializeToObject newInstance(class scala.Tuple2), obj#2829: scala.Tuple2
      +- Project [cast(key#2805 as string) AS key#2819, cast(value#2806 as string) AS value#2820]
         +- StreamingDataSourceV2Relation [key#2805, value#2806, topic#2807, partition#2808, offset#2809L, timestamp#2810, timestampType#2811], org.apache.spark.sql.kafka010.KafkaSourceProvider$KafkaScan@26c84727, KafkaSource[SubscribePattern[failOnDataLoss.*]]

      at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:351)
      at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:242)
      Cause: java.lang.InterruptedException
      at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1326)
      at scala.concurrent.impl.Promise$DefaultPromise.tryAwait(Promise.scala:248)
      at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:258)
      at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:263)
      at org.apache.spark.util.ThreadUtils$.awaitResult(ThreadUtils.scala:220)
      at org.apache.spark.rpc.RpcTimeout.awaitResult(RpcTimeout.scala:75)
      at org.apache.spark.rpc.RpcEndpointRef.askSync(RpcEndpointRef.scala:92)
      at org.apache.spark.rpc.RpcEndpointRef.askSync(RpcEndpointRef.scala:76)
      at org.apache.spark.sql.execution.streaming.continuous.ContinuousExecution.runContinuous(ContinuousExecution.scala:271)
      at org.apache.spark.sql.execution.streaming.continuous.ContinuousExecution.runActivatedStream(ContinuousExecution.scala:109)
      at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:330)
      at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:242)
</code></pre>