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 <[email protected]> Authored: Tue Sep 15 10:02:06 2015 -0700 Committer: Gaurav <[email protected]> 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 {
