[ https://issues.apache.org/jira/browse/FLINK-11403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang updated FLINK-11403: ----------------------------- Summary: Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition (was: Remove ResultPartitionConsumableNotifier from ResultPartition) > Introduce ResultPartitionWithConsumableNotifier in task for notifying > consumable result partition > -------------------------------------------------------------------------------------------------- > > Key: FLINK-11403 > URL: https://issues.apache.org/jira/browse/FLINK-11403 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Network > Reporter: zhijiang > Assignee: zhijiang > Priority: Minor > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > The creation of {{ResultPartitionWriter}} from {{NetworkEnvironment}} relies > on {{TaskAction}}, {{ResultPartitionConsumableNotifier}}. For breaking this > tie, {{ResultPartitionWithConsumableNotifier}} is introduced for wrapping the > logic of notification. > In this way the later interface method > {{ShuffleService#createResultPartitionWriter}} would be simple. -- This message was sent by Atlassian JIRA (v7.6.3#76005)