Skip to content

[Feature Request]: Create a merge-on-read Iceberg sink #39979

Description

@ahmedabu98

What would you like to happen?

We have an append-only IcebergIO sink.

This is a request to extend the Iceberg sink so that it can receive CDC (insert, update, delete) records from an upstream source and apply them to an Iceberg table.

Issue Priority

Priority: 2 (default / most feature requests should be filed as P2)

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Infrastructure
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Prism Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner

Activity

  1. self-assigned this
    on Sep 2, 2026
  2. ahmedabu98 commented on Sep 2, 2026

    @ahmedabu98
    ContributorAuthor

    Full change: #39978

    Will break it up into separate PRs

  3. added this to the 2.77.0 Release milestone on Sep 16, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

Projects

No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions