Skip to content

[Iceberg CDC sink] Split late data and create commit windows - #40006

Open
ahmedabu98 wants to merge 1 commit into
apache:masterfrom
ahmedabu98:cdc-commit-windows
Open

[Iceberg CDC sink] Split late data and create commit windows#40006
ahmedabu98 wants to merge 1 commit into
apache:masterfrom
ahmedabu98:cdc-commit-windows

Conversation

@ahmedabu98

Copy link
Copy Markdown
Contributor

Adds the CDC sink's windowing stage:

  • CommitWindows groups each destination's keyed changes into event-time commit windows and sorts them by primary key and sequence number via SortValues transform
  • SplitLateData diverts every late pane to a replayable dead-letter output instead of letting it reach a window the committer may already have sealed.

Needs #39997 to get merged first.

Part of #39979


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

  • Mention the appropriate issue in your description (for example: addresses #123), if applicable. This will automatically add a link to the pull request in the issue. If you would like the issue to automatically close on merging the pull request, comment fixes #<ISSUE NUMBER> instead.
  • Update CHANGES.md with noteworthy changes.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

See the Contributor Guide for more tips on how to make review process smoother.

To check the build health, please visit https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels
Python tests
Java tests
Go tests

See CI.md for more information about GitHub Actions CI or the workflows README to see a list of phrases to trigger workflows.

@ahmedabu98 ahmedabu98 changed the title [Iceberg] Split late data and create commit windows [Iceberg CDC sink] Split late data and create commit windows Sep 3, 2026
@github-actions

github-actions Bot commented Sep 4, 2026

Copy link
Copy Markdown
Contributor

Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment assign set of reviewers

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant