azagrebin commented on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-508110562 I agree with @zhijiangW. We should use `ShuffleMaster#registerPartitionWithProducer` to obtain `ShuffleDescriptor` for cached partitions as we do it for any others. The idea is that concrete implementation of `ShuffleDescriptor` contains enough information to consume the cached partition later using the same shuffle service which produced it. Execution graph and client code should be completely oblivious to the internals of `ShuffleDescriptor`.
---------------------------------------------------------------- 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
