Repository: incubator-apex-core Updated Branches: refs/heads/release-3.2 e4eadadab -> 39d675d61
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/39d675d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/39d675d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/39d675d6 Branch: refs/heads/release-3.2 Commit: 39d675d61af1342a2c13943c433f767ac096ac83 Parents: e4eadad Author: ishark <[email protected]> Authored: Thu Mar 17 11:33:24 2016 -0700 Committer: ishark <[email protected]> Committed: Thu Mar 17 11:33:24 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/39d675d6/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 82fe454..d3f674a 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;
