zhijiangW commented on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-525999658 Thanks for the further review. The failure compilation is caused by `StreamTwoInputProcessor` which I have adjusted before because it would be removed finally by another ongoing PR. I could wait for that PR merged and rebase on that. Also wait for some progress in `SourceReader`.
---------------------------------------------------------------- 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 With regards, Apache Git Services
