Fabian Paul created FLINK-29583:
-----------------------------------
Summary: Ensure correct subtaskId and checkpointId is set during
committer state migration
Key: FLINK-29583
URL: https://issues.apache.org/jira/browse/FLINK-29583
Project: Flink
Issue Type: Bug
Components: Connectors / Common
Affects Versions: 1.15.2, 1.16.0, 1.17.0
Reporter: Fabian Paul
We already discovered two problems during recovery of committers when a post
commit topology is used
* https://issues.apache.org/jira/browse/FLINK-29509
* https://issues.apache.org/jira/browse/FLINK-29512
Both problems also apply when recovering Flink 1.14 unified sinks committer
state and migrate it to the extended unified model.
As part of this ticket we should fix both issues for the migration and also
increase the test coverage for the migration cases i.e. add test cases in
CommitterOperatorTest and CommittableCollectorSerializerTest.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
