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 <[email protected]> Authored: Mon Oct 24 10:44:29 2016 -0700 Committer: Markus Weimer <[email protected]> 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(); } }
