[
https://issues.apache.org/jira/browse/FLINK-19632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-19632:
-----------------------------
Description:
# On downstream node failure, the upstream node needs to release sub-partition
view while keeping the result partition.
# When the downstream node reconnects, the subpartition view needs to be
recreated. If the previous subpartition view still exists, it needs to be
released.
Clean up of the partial records should be handled in RT-383
> Introduce a new ResultPartitionType for Approximate Local Recovery
> ------------------------------------------------------------------
>
> Key: FLINK-19632
> URL: https://issues.apache.org/jira/browse/FLINK-19632
> Project: Flink
> Issue Type: Sub-task
> Reporter: Yuan Mei
> Priority: Major
>
> # On downstream node failure, the upstream node needs to release
> sub-partition view while keeping the result partition.
> # When the downstream node reconnects, the subpartition view needs to be
> recreated. If the previous subpartition view still exists, it needs to be
> released.
> Clean up of the partial records should be handled in RT-383
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
