You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/09 03:24:00 UTC

[jira] [Updated] (FLINK-19547) Partial record clean up after receiver task fails and restart

     [ https://issues.apache.org/jira/browse/FLINK-19547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yuan Mei updated FLINK-19547:
-----------------------------
    Summary: Partial record clean up after receiver task fails and restart  (was: Partial record clean Up after receiver task fails and restart)

> Partial record clean up after receiver task fails and restart
> -------------------------------------------------------------
>
>                 Key: FLINK-19547
>                 URL: https://issues.apache.org/jira/browse/FLINK-19547
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Network
>    Affects Versions: 1.12.0
>            Reporter: Yuan Mei
>            Priority: Major
>
> In the mode of approximate local recovery, the problem of partial record occurs when a record is spanning over multiple buffers. If the first (several) buffers have already been sent over the network and then get lost due to the failure of the receiver task, the remaining data belonging to the same record in transition should be cleaned up.



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