dawidwys commented on a change in pull request #13529:
URL: https://github.com/apache/flink/pull/13529#discussion_r502225272
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java
##########
@@ -45,16 +45,16 @@
private final StreamTaskInput<IN> input;
private final DataOutput<IN> output;
- private final OperatorChain<?, ?> operatorChain;
+ private final BoundedMultiInput endOfInputAware;
public StreamOneInputProcessor(
StreamTaskInput<IN> input,
DataOutput<IN> output,
- OperatorChain<?, ?> operatorChain) {
+ BoundedMultiInput endOfInputAware) {
Review comment:
`StreamMultipleInputProcessor` needs the `OperatorChain` for extracting
chained sources. I updated it in the `StreamTwoInputProcessor` 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:
us...@infra.apache.org
