Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20253#discussion_r161358227
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDDIter.scala
---
@@ -177,6 +176,7 @@ class DataReaderThread(
private[continuous] var failureReason: Throwable = _
override def run(): Unit = {
+ TaskContext.setTaskContext(context)
--- End diff --
This line was added since the last PR. Why is this needed?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
