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