[SYSTEMML-2238] Fix robustness parfor worker cleanup w/o created pool Project: http://git-wip-us.apache.org/repos/asf/systemml/repo Commit: http://git-wip-us.apache.org/repos/asf/systemml/commit/6fa83d39 Tree: http://git-wip-us.apache.org/repos/asf/systemml/tree/6fa83d39 Diff: http://git-wip-us.apache.org/repos/asf/systemml/diff/6fa83d39
Branch: refs/heads/master Commit: 6fa83d392cf0a5957dbd5035cdb1e9a96e823277 Parents: c243186 Author: Matthias Boehm <mboe...@gmail.com> Authored: Fri Apr 13 17:08:37 2018 -0700 Committer: Matthias Boehm <mboe...@gmail.com> Committed: Fri Apr 13 17:08:37 2018 -0700 ---------------------------------------------------------------------- .../apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/systemml/blob/6fa83d39/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java b/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java index 058026c..f6cb602 100644 --- a/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java +++ b/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/LocalParWorker.java @@ -138,7 +138,7 @@ public class LocalParWorker extends ParWorker implements Runnable } finally { //cleanup fair scheduler pool for worker thread - if( OptimizerUtils.isSparkExecutionMode() ) { + if( OptimizerUtils.isSparkExecutionMode() && pool != -1 ) { SparkExecutionContext sec = (SparkExecutionContext)_ec; sec.cleanupThreadLocalSchedulerPool(pool); }
