[jira] [Resolved] (FLINK-36368) Fix subtask management in CommittableCollector

["Arvid Heise (Jira)" <ji...@apache.org>]

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

Arvid Heise resolved FLINK-36368.
---------------------------------
    Resolution: Fixed

Merged into main as 8dc212c32036c3a4afd3af2e50e95cb87c8cee23.

> Fix subtask management in CommittableCollector 
> -----------------------------------------------
>
>                 Key: FLINK-36368
>                 URL: https://issues.apache.org/jira/browse/FLINK-36368
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Arvid Heise
>            Assignee: Arvid Heise
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.0-preview
>
>
> CommittableCollector is owned by a specific committer subtask and may handle a number of upstream tasks emitting committables.
> Currently, CommittableCollector rewrites the subtask id to its owner upon receiving a committable (summary). However, this makes it impossible to track if a specific upstream subtask has sent all committables or not.
> I propose to stop rewriting the subtask id while collecting the committables and instead rewrite them only on emission. This should also ease debugging the state.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)