Repository: incubator-reef Updated Branches: refs/heads/master 4aeef3e9e -> 3686fae2b
[REEF-635] Record failed Evaluators only once during restart This removes the remove evaluator log call from YarnDriverRuntimeRestartManager. JIRA: [REEF-635](https://issues.apache.org/jira/browse/REEF-635) Pull Request: This closes #406 Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/3686fae2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/3686fae2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/3686fae2 Branch: refs/heads/master Commit: 3686fae2b36a9adf5eb10d9030e6f9f3d7130680 Parents: 4aeef3e Author: Andrew Chung <[email protected]> Authored: Sat Aug 22 18:47:04 2015 -0700 Committer: Markus Weimer <[email protected]> Committed: Mon Aug 24 09:19:03 2015 -0700 ---------------------------------------------------------------------- .../reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/3686fae2/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java index d076e2d..fbf64f8 100644 --- a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java +++ b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/YarnDriverRuntimeRestartManager.java @@ -189,7 +189,6 @@ public final class YarnDriverRuntimeRestartManager implements DriverRuntimeResta } for (final String expectedContainerId : expectedContainers) { if (!previousContainersIds.contains(expectedContainerId)) { - this.evaluatorPreserver.recordRemovedEvaluator(expectedContainerId); LOG.log(Level.WARNING, "Expected container [{0}] not alive, must have failed during driver restart.", expectedContainerId); failedEvaluators.add(expectedContainerId);
