[FLINK-3525] [runtime] Fix call to super.close() in TimestampsAndPeriodicWatermarksOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2de20b0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2de20b0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f2de20b0 Branch: refs/heads/release-1.0 Commit: f2de20b02bef66f437164e24e9fc0084530d4b01 Parents: 8c33015 Author: Stephan Ewen <[email protected]> Authored: Fri Feb 26 18:19:27 2016 +0100 Committer: Robert Metzger <[email protected]> Committed: Fri Feb 26 20:57:04 2016 +0100 ---------------------------------------------------------------------- .../runtime/operators/TimestampsAndPeriodicWatermarksOperator.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f2de20b0/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndPeriodicWatermarksOperator.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndPeriodicWatermarksOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndPeriodicWatermarksOperator.java index a1614c0..92faed2 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndPeriodicWatermarksOperator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndPeriodicWatermarksOperator.java @@ -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) {
