dawidwys commented on a change in pull request #13423:
URL: https://github.com/apache/flink/pull/13423#discussion_r493587579
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java
##########
@@ -268,7 +252,12 @@ public InputProcessor(
}
public InputStatus processInput() throws Exception {
- return taskInput.emitNext(dataOutput);
+ InputStatus status = taskInput.emitNext(dataOutput);
+ if (status == InputStatus.END_OF_INPUT) {
+ dataOutput.endOutput();
Review comment:
After taking the previous comment into consideration, I think this will
make sense. The `taskInput` will not be aware of the `endOutput` method any
more, the `Processor` will though.
----------------------------------------------------------------
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:
[email protected]
