dawidwys commented on a change in pull request #13521:
URL: https://github.com/apache/flink/pull/13521#discussion_r499603772
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java
##########
@@ -100,6 +111,27 @@ public void init() throws Exception {
getEnvironment().getMetricGroup().gauge(MetricNames.IO_CURRENT_INPUT_WATERMARK,
this.inputWatermarkGauge::getValue);
}
+ private StreamTaskInput<IN> wrapWithSorted(StreamTaskInput<IN> input) {
Review comment:
Yes, the other tasks will be handled in separate PRs (I already opened a
draft for two input: https://github.com/apache/flink/pull/13529 which lacks
mostly comments).
Sure I will add exceptions, even though I think it is in a releasable shape
already. The feature is not exposed to users, there is no straightforward way
to enable it. The only way is to edit the StreamGraph manually, as I am doing
in a test, but that's a hack.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
