[GitHub] [flink] lindong28 commented on pull request #21576: [FLINK-30533][runtime] SourceOperator#emitNext() should push records to DataOutput in a while loop

2023-01-03 Thread GitBox
lindong28 commented on PR #21576: URL: https://github.com/apache/flink/pull/21576#issuecomment-1369812187 @zhuzhurk Thanks for the review! After reading through related source code, I believe this PR won't affect the behavior of multi-input operators, due to the following reasons:

[GitHub] [flink] lindong28 commented on pull request #21576: [FLINK-30533][runtime] SourceOperator#emitNext() should push records to DataOutput in a while loop

2023-01-02 Thread GitBox
lindong28 commented on PR #21576: URL: https://github.com/apache/flink/pull/21576#issuecomment-1369329109 @xintongsong @zhuzhurk Can you review this PR? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL