You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by we...@apache.org on 2016/10/24 19:57:18 UTC
reef git commit: [REEF-1650] Warn about unclean evaluator shutdown
only if evaluator is not closing yet
Repository: reef
Updated Branches:
refs/heads/master 556bda809 -> 5a1c60f5a
[REEF-1650] Warn about unclean evaluator shutdown only if evaluator is not closing yet
JIRA:
[REEF-1650](https://issues.apache.org/jira/browse/REEF-1650)
Pull request:
This closes #1165
Project: http://git-wip-us.apache.org/repos/asf/reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/5a1c60f5
Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/5a1c60f5
Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/5a1c60f5
Branch: refs/heads/master
Commit: 5a1c60f5a0f7e548e8acfd234ec320c96d7398e6
Parents: 556bda8
Author: Mariia Mykhailova <ma...@apache.org>
Authored: Mon Oct 24 10:44:29 2016 -0700
Committer: Markus Weimer <we...@apache.org>
Committed: Mon Oct 24 12:55:25 2016 -0700
----------------------------------------------------------------------
.../apache/reef/runtime/common/driver/evaluator/Evaluators.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/reef/blob/5a1c60f5/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/Evaluators.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/Evaluators.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/Evaluators.java
index 341d37d..68a122d 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/Evaluators.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/Evaluators.java
@@ -70,8 +70,8 @@ public final class Evaluators implements AutoCloseable {
evaluatorsCopy = new ArrayList<>(this.evaluators.values());
}
for (final EvaluatorManager evaluatorManager : evaluatorsCopy) {
- LOG.log(Level.WARNING, "Unclean shutdown of evaluator {0}", evaluatorManager.getId());
if (!evaluatorManager.isClosedOrClosing()) {
+ LOG.log(Level.WARNING, "Unclean shutdown of evaluator {0}", evaluatorManager.getId());
evaluatorManager.close();
}
}