diff options
| author | Aaron Davidson <aaron@databricks.com> | 2014-04-23 16:52:49 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-04-23 16:52:49 -0700 |
| commit | 432201c7ee9e1ea1d70a6418cbad1c5ad2653ed3 (patch) | |
| tree | 83885c8515418ff00f9d20673bfe21f4dbe9daf9 /.travis.yml | |
| parent | dd1b7a61d9193c93ab95ab550622259f4bc26f53 (diff) | |
| download | spark-432201c7ee9e1ea1d70a6418cbad1c5ad2653ed3.tar.gz spark-432201c7ee9e1ea1d70a6418cbad1c5ad2653ed3.tar.bz2 spark-432201c7ee9e1ea1d70a6418cbad1c5ad2653ed3.zip | |
SPARK-1582 Invoke Thread.interrupt() when cancelling jobs
Sometimes executor threads are blocked waiting for IO or monitors, and the current implementation of job cancellation may never recover these threads. By simply invoking Thread.interrupt() during cancellation, we can often safely unblock the threads and use them for subsequent work.
Note that this feature must remain optional for now because of a bug in HDFS where Thread.interrupt() may cause nodes to be marked as permanently dead (as the InterruptedException is reinterpreted as an IOException during communication with some node).
Author: Aaron Davidson <aaron@databricks.com>
Closes #498 from aarondav/cancel and squashes the following commits:
e52b829 [Aaron Davidson] Don't use job.properties when null
82f78bb [Aaron Davidson] Update DAGSchedulerSuite
b67f472 [Aaron Davidson] Add comment on why interruptOnCancel is in setJobGroup
4cb9fd6 [Aaron Davidson] SPARK-1582 Invoke Thread.interrupt() when cancelling jobs
Diffstat (limited to '.travis.yml')
0 files changed, 0 insertions, 0 deletions