提交 5e769b38 编写于 作者: S Stephan Ewen

[FLINK-3525] [runtime] Fix call to super.close() in TimestampsAndPeriodicWatermarksOperator

上级 6a28a6f4
......@@ -91,6 +91,8 @@ public class TimestampsAndPeriodicWatermarksOperator<T>
@Override
public void close() throws Exception {
super.close();
// emit a final watermark
Watermark newWatermark = userFunction.getCurrentWatermark();
if (newWatermark != null && newWatermark.getTimestamp() > currentWatermark) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册