Repository: flink Updated Branches: refs/heads/master e5057b72c -> d160b5e56
[hotfix] Remove auto-boxing in ContinuousEventTimeTrigger Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d160b5e5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d160b5e5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d160b5e5 Branch: refs/heads/master Commit: d160b5e56fb40a0872a59c64d9ca3377d4cf4e86 Parents: e5057b7 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Thu Mar 16 14:11:18 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Mar 16 14:12:28 2017 +0100 ---------------------------------------------------------------------- .../api/windowing/triggers/ContinuousEventTimeTrigger.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d160b5e5/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java index 3e31c09..ef1dbcf 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java @@ -81,7 +81,7 @@ public class ContinuousEventTimeTrigger<W extends Window> extends Trigger<Object Long fireTimestamp = fireTimestampState.get(); - if (fireTimestamp != null && fireTimestamp.equals(time)) { + if (fireTimestamp != null && fireTimestamp == time) { fireTimestampState.clear(); fireTimestampState.add(time + interval); ctx.registerEventTimeTimer(time + interval);
