-
- Downloads
[SPARK-21248][SS] The clean up codes in StreamExecution should not be interrupted
## What changes were proposed in this pull request? This PR uses `runUninterruptibly` to avoid that the clean up codes in StreamExecution is interrupted. It also removes an optimization in `runUninterruptibly` to make sure this method never throw `InterruptedException`. ## How was this patch tested? Jenkins Author: Shixiong Zhu <shixiong@databricks.com> Closes #18461 from zsxwing/SPARK-21248.
Showing
- core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala 1 addition, 9 deletions...n/scala/org/apache/spark/util/UninterruptibleThread.scala
- core/src/test/scala/org/apache/spark/util/UninterruptibleThreadSuite.scala 2 additions, 3 deletions...la/org/apache/spark/util/UninterruptibleThreadSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala 5 additions, 1 deletion...pache/spark/sql/execution/streaming/StreamExecution.scala
Loading
Please register or sign in to comment