commit c03f05da96c66cd1a25cffcd5f15d2b22f5e2b4c
author gaurav gupta <gaugupt3@cisco.com> Thu Jul 07 20:23:44 2016 -0700
committer gaurav gupta <gaugupt3@cisco.com> Thu Jul 07 20:23:44 2016 -0700
tree 03f5a8ac2dbb154c16f805160331cca830e7fb94
parent 558942aa584aad9d9de72fbae466e8a2039e79c2

Fixed the typo while determing the pending deploy for strongly connected group

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 @@
           // 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