Thesharing commented on pull request #16856: URL: https://github.com/apache/flink/pull/16856#issuecomment-903605002
I've tried to improve my pull request according to our discussion above. Now `PartitionReleaseStrategy#vertexFinished` will return a list of releasable ConsumedPartitionGroups instead of IntermediateResultPartitions. And it makes `DefaultExecutioGraph#releasePartitions` looks clearer. Since the hotfix to get rid of the assumption that "one IntermediateDataSet can have multiple consumer JobVertices will also be added" will involve too many code changes, I think maybe it's better to open another JIRA for it. @tillrohrmann and @zhuzhurk Would you mind reviewing the updated PR if you got any free time? -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
