dawidwys commented on a change in pull request #13529:
URL: https://github.com/apache/flink/pull/13529#discussion_r501825284
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java
##########
@@ -62,6 +62,16 @@ public StreamOneInputProcessor(
return input.getAvailableFuture();
}
+ @Override
+ public boolean isAvailable() {
+ return input.isAvailable();
+ }
+
+ @Override
+ public boolean isApproximatelyAvailable() {
+ return input.isApproximatelyAvailable();
+ }
+
Review comment:
It is the same if the input does not override default implementations.
Mine does.
----------------------------------------------------------------
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
