zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#issuecomment-459007355 FYI, this PR is based on #7593 which could get the flag of `sendScheduleOrUpdateConsumers` from TDD directly, so I include that commit. I would add some new tests in `RecordWriterTest` to verify the logic for `notifyPipelinedConsumers` after confirming the main logic changes make sense.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on 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