提交 b670b11f 编写于 作者: T Timo Walther

[FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy

This closes #9241.
上级 c5b133e6
......@@ -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
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册