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-533194969
Yes, it is better to merge this PR soon if no other concerns. Because there
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-529754407
Thanks for the review and good suggestions @1u0 !
I agree that `pull`
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-527070252
Thanks for the notification and I already rebased the master. It is
freiendly
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
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-525565847
Thanks for the review @pnowojski !
I have submitted the fixup commit
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-525236060
@pnowojski this pr is ready for review and I have not changed the