-
- Downloads
[SPARK-1745] Move interrupted flag from TaskContext constructor (minor)
It makes little sense to start a TaskContext that is interrupted. Indeed, I searched for all use cases of it and didn't find a single instance in which `interrupted` is true on construction. This was inspired by reviewing #640, which adds an additional `@volatile var completed` that is similar. These are not the most urgent changes, but I wanted to push them out before I forget. Author: Andrew Or <andrewor14@gmail.com> Closes #675 from andrewor14/task-context and squashes the following commits: 9575e02 [Andrew Or] Add space 69455d1 [Andrew Or] Merge branch 'master' of github.com:apache/spark into task-context c471490 [Andrew Or] Oops, removed one flag too many. Adding it back. 85311f8 [Andrew Or] Move interrupted flag from TaskContext constructor
Showing
- core/src/main/scala/org/apache/spark/TaskContext.scala 11 additions, 9 deletionscore/src/main/scala/org/apache/spark/TaskContext.scala
- core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala 1 addition, 2 deletions...ain/scala/org/apache/spark/scheduler/ShuffleMapTask.scala
- core/src/test/java/org/apache/spark/JavaAPISuite.java 1 addition, 1 deletioncore/src/test/java/org/apache/spark/JavaAPISuite.java
- core/src/test/scala/org/apache/spark/CacheManagerSuite.scala 3 additions, 7 deletionscore/src/test/scala/org/apache/spark/CacheManagerSuite.scala
- core/src/test/scala/org/apache/spark/PipedRDDSuite.scala 1 addition, 3 deletionscore/src/test/scala/org/apache/spark/PipedRDDSuite.scala
Loading
Please register or sign in to comment