flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [hotfix] Remove auto-boxing in ContinuousEventTimeTrigger
Date Thu, 16 Mar 2017 13:12:55 GMT
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.krettek@gmail.com>
Authored: Thu Mar 16 14:11:18 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@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);


Mime
View raw message