flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yuan Mei (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-19632) Introduce a new ResultPartitionType for Approximate Local Recovery
Date Mon, 26 Oct 2020 09:56:00 GMT

     [ 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 a 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 a separate Jira ticket FLINK-19547

 

  was:
# 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 a separate ticket

 


> 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
>          Components: Runtime / Task
>            Reporter: Yuan Mei
>            Priority: Major
>              Labels: pull-request-available
>
> # On downstream node failure, the upstream node needs to release a 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 a separate Jira ticket FLINK-19547
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message