apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From che...@apache.org
Subject [1/2] incubator-apex-core git commit: APEX-126 #comment made sure that handleIdleTime is called inside window boundaries
Date Tue, 15 Sep 2015 19:20:09 GMT
Repository: incubator-apex-core
Updated Branches:
  refs/heads/release-3.1 525ff187f -> d00620448


APEX-126 #comment made sure that handleIdleTime is called inside window boundaries


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/c436f251
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/c436f251
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/c436f251

Branch: refs/heads/release-3.1
Commit: c436f25190f04f2ff44f8dcb840f63035ec7d343
Parents: 525ff18
Author: Gaurav <gaurav@datatorrent.com>
Authored: Tue Sep 15 10:02:06 2015 -0700
Committer: Gaurav <gaurav@datatorrent.com>
Committed: Tue Sep 15 10:19:55 2015 -0700

----------------------------------------------------------------------
 engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/c436f251/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java b/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java
index 2a56a49..20795ce 100644
--- a/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java
+++ b/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java
@@ -512,7 +512,7 @@ public class GenericNode extends Node<Operator>
           }
 
           if (need2sleep) {
-            if (handleIdleTime) {
+            if (handleIdleTime && insideWindow) {
               ((IdleTimeHandler) operator).handleIdleTime();
             }
             else {


Mime
View raw message