kumarpritam863 opened a new pull request, #18857: URL: https://github.com/apache/iceberg/pull/18857
The dynamic sink committer skips a commit when the ancestry it validates against already holds the same sink, operator and checkpoint. For a branch with no ref yet, that ancestry is the one of main, so if main committed the same checkpoint first, the first commit to the branch was skipped as a duplicate and its data was dropped silently. The validation is now skipped while the branch has no ref. It runs on every attempt, so a retry after the commit created the branch is still recognized as a duplicate. This is Flink 2.3 only; backports follow. Test plan: `firstCommitToNewBranchIsNotSkippedWhenMainCommittedSameCheckpoint` fails without the change, and `repeatedCommitToBranchCreatedByTheCommitIsSkipped` guards the retry case. The `sink.dynamic` tests pass. --- **AI Disclosure** - Model: Claude Sonnet 5.5 - Platform/Tool: Claude Code -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
