Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4702#discussion_r140528890
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingKeyedTimePanes.java
---
@@ -212,6 +213,11 @@ public KeyedStateStore windowState() {
public KeyedStateStore globalState() {
return globalState;
}
+
+ @Override
+ public <X> void output(OutputTag<X> outputTag, X value) {
+ throw new UnsupportedOperationException("current
watermark is not supported in this context");
--- End diff --
Still has the old message about watermarks.
---
