We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fb27a97 commit 7317b0fCopy full SHA for 7317b0f
1 file changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
@@ -178,8 +178,8 @@ class StreamExecution(
178
179
/**
180
* The thread that runs the micro-batches of this stream. Note that this thread must be
181
- * [[org.apache.spark.util.UninterruptibleThread]] to avoid swallowing `InterruptException` when
182
- * using [[HDFSMetadataLog]]. See SPARK-19599 for more details.
+ * [[org.apache.spark.util.UninterruptibleThread]] to workaround KAFKA-1894: interrupting a
+ * running `KafkaConsumer` may cause endless loop.
183
*/
184
val microBatchThread =
185
new StreamExecutionThread(s"stream execution thread for $prettyIdString") {
0 commit comments