Skip to content

[Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match #40853

Open

Description

@chamikaramj

What happened?

This is needed for consistency of the data read from the Delta Lake CDC source.

public abstract static class ReadChanges extends PTransform<PBegin, PCollection<Row>> {

Issue Priority

Priority: 2 (default / most bugs 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 Oct 27, 2026
  2. added this to the 2.78.0 Release milestone on Oct 27, 2026
  3. jrmccluskey commented on Oct 28, 2026

    @jrmccluskey
    Contributor

    Do we have an ETA on a fix for this?

  4. chamikaramj commented on Oct 28, 2026

    @chamikaramj
    ContributorAuthor

    I'm working on a fix and will get it out today.

  5. chamikaramj commented on Oct 28, 2026

    @chamikaramj
    ContributorAuthor

    Opened #40868.

  6. chamikaramj commented on Oct 28, 2026

    @chamikaramj
    ContributorAuthor

    Fix is in but we need to cherry-pick to the release branch.

  7. chamikaramj commented on Oct 28, 2026

    @chamikaramj
    ContributorAuthor

    Opened #40877.

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

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions