You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@systemml.apache.org by mb...@apache.org on 2018/04/14 01:00:00 UTC
[3/4] systemml git commit: [SYSTEMML-2238] Fix robustness parfor
worker cleanup w/o created pool
[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 <mb...@gmail.com>
Authored: Fri Apr 13 17:08:37 2018 -0700
Committer: Matthias Boehm <mb...@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);
}