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 <[email protected]> Authored: Thu Jul 7 20:23:44 2016 -0700 Committer: gaurav gupta <[email protected]> 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
