You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/15 20:55:19 UTC
[1/2] incubator-apex-core git commit: APEX-126 #comment made sure
that handleIdleTime is called inside window boundaries
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 c0baa9d9b -> 0936445bd
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/7801b7a3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/7801b7a3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/7801b7a3
Branch: refs/heads/devel-3
Commit: 7801b7a3af777afc26cda26fcbb0f11c25d3cbcd
Parents: c0baa9d
Author: Gaurav <ga...@datatorrent.com>
Authored: Tue Sep 15 10:02:06 2015 -0700
Committer: Gaurav <ga...@datatorrent.com>
Committed: Tue Sep 15 10:02:06 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/7801b7a3/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 {
[2/2] incubator-apex-core git commit: Merge branch
'gaurav-IdleTimeHandler' into devel-3
Posted by ch...@apache.org.
Merge branch 'gaurav-IdleTimeHandler' into devel-3
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/0936445b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/0936445b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/0936445b
Branch: refs/heads/devel-3
Commit: 0936445bd06f68abd899eff2cac5f2cbb01cbaf7
Parents: c0baa9d 7801b7a
Author: Chetan Narsude <ch...@datatorrent.com>
Authored: Tue Sep 15 11:54:45 2015 -0700
Committer: Chetan Narsude <ch...@datatorrent.com>
Committed: Tue Sep 15 11:54:45 2015 -0700
----------------------------------------------------------------------
engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------