You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/07/29 08:02:45 UTC
[flink] branch master updated: [FLINK-13429][table-common] Fix
BoundedOutOfOrderTimestamps watermark strategy
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b670b11 [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy
b670b11 is described below
commit b670b11f303657aa8175ec933ee29b377cb9e087
Author: Timo Walther <tw...@apache.org>
AuthorDate: Fri Jul 26 15:14:42 2019 +0200
[FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy
This closes #9241.
---
.../flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java
index 725f534..1ddbc31 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java
@@ -36,13 +36,14 @@ public final class BoundedOutOfOrderTimestamps extends PeriodicWatermarkAssigner
private static final long serialVersionUID = 1L;
private final long delay;
- private long maxTimestamp = Long.MIN_VALUE + 1;
+ private long maxTimestamp;
/**
* @param delay The delay by which watermarks are behind the maximum observed timestamp.
*/
public BoundedOutOfOrderTimestamps(long delay) {
this.delay = delay;
+ maxTimestamp = Long.MIN_VALUE + delay;
}
@Override