Repository: incubator-apex-core Updated Branches: refs/heads/release-3.3 1a59c3c41 -> 68964195a
Disable blacklisting of failed nodes by default Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/68964195 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/68964195 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/68964195 Branch: refs/heads/release-3.3 Commit: 68964195a100bae70a03548e50d389364f6547eb Parents: 1a59c3c Author: ishark <[email protected]> Authored: Thu Mar 17 11:33:24 2016 -0700 Committer: Thomas Weise <[email protected]> Committed: Thu Mar 17 17:48:56 2016 -0700 ---------------------------------------------------------------------- .../java/com/datatorrent/stram/StreamingAppMasterService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/68964195/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java b/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java index 8565275..3b2c4de 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java @@ -104,6 +104,7 @@ public class StreamingAppMasterService extends CompositeService private static final int NUMBER_MISSED_HEARTBEATS = 30; private static final int MAX_CONTAINER_FAILURES_PER_NODE = 3; private static final long BLACKLIST_REMOVAL_TIME = 60 * 60 * 1000; + private boolean enableFailedNodeBlacklisting = false; private AMRMClient<ContainerRequest> amRmClient; private NMClientAsync nmClient; private LogicalPlan dag; @@ -898,7 +899,7 @@ public class StreamingAppMasterService extends CompositeService if (0 != exitStatus) { if (allocatedContainer != null) { numFailedContainers.incrementAndGet(); - if (exitStatus != 1) { + if (exitStatus != 1 && enableFailedNodeBlacklisting) { // If container failure due to framework String hostname = allocatedContainer.container.getNodeId().getHost(); int failedTimes = 1;
