[
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)