azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-469636966 @zhijiangW I agree we need to revisit this topic after shuffle refactoring @QiLuo-BD What do you think if we keep releasing of partitions as it is now but add a separate `isClosed` flag to subpartition/partition and use it instead of `isReleased`? The `PartitionRequestQueue.close` and `PartitionRequestQueue.channelInactive` could notify read view and subsequently subpartition/partition that it is closed. The task/slot could use `partition.isClosed` flag instead of `isReeleased` to report to resource manager that task executor can be released the same way as it is now in PR.
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
