zhijiangW commented on issue #7549: [FLINK-11403][network] Remove 
ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549#issuecomment-462638845
 
 
   @azagrebin , thanks for your reviews!
   
   I think your suggestion makes sense and is worth trying. We wrap the 
`ResultPartition` created from `ShuffleService` and other fields related to 
consumption notification in a separate new class. Then the `RecordWriter` and 
`Task` only see this new wrapped class avoid of spreading tiny ones anywhere.
   
   I would have a try and re-submit the codes when ready.

----------------------------------------------------------------
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

Reply via email to