You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2015/09/24 04:37:47 UTC
[28/50] [abbrv] incubator-apex-core git commit: APEX-126 #comment
made sure that handleIdleTime is called inside window boundaries
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/feature-module
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 {