Arvid Heise created FLINK-36368:
-----------------------------------
Summary: 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
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)
