apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject incubator-apex-core git commit: Disable blacklisting of failed nodes by default
Date Fri, 18 Mar 2016 00:49:39 GMT
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 <isha@datatorrent.com>
Authored: Thu Mar 17 11:33:24 2016 -0700
Committer: Thomas Weise <thomas@datatorrent.com>
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;


Mime
View raw message