You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/07/09 19:27:48 UTC
apex-core git commit: Fixed the typo while determing the pending
deploy for strongly connected group
Repository: apex-core
Updated Branches:
refs/heads/master 558942aa5 -> c03f05da9
Fixed the typo while determing the pending deploy for strongly connected group
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/c03f05da
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/c03f05da
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/c03f05da
Branch: refs/heads/master
Commit: c03f05da96c66cd1a25cffcd5f15d2b22f5e2b4c
Parents: 558942a
Author: gaurav gupta <ga...@cisco.com>
Authored: Thu Jul 7 20:23:44 2016 -0700
Committer: gaurav gupta <ga...@cisco.com>
Committed: Thu Jul 7 20:23:44 2016 -0700
----------------------------------------------------------------------
.../main/java/com/datatorrent/stram/StreamingContainerManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/c03f05da/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
index b12709e..092f5a2 100644
--- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
+++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
@@ -1998,7 +1998,7 @@ public class StreamingContainerManager implements PlanContext
// visit all downstream operators of the group
ctx.visited.add(groupOper);
groupOpers.add(groupOper);
- pendingDeploy |= operator.getState() == PTOperator.State.PENDING_DEPLOY;
+ pendingDeploy |= groupOper.getState() == PTOperator.State.PENDING_DEPLOY;
}
}
// highest common checkpoint