[flink] branch release-1.9 updated: [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy

[twalthr]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 0224d9b  [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps 
watermark strategy
0224d9b is described below

commit 0224d9bc0a773633943282f5268770a8063a87a2
Author: Timo Walther <twal...@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