This is an automated email from the ASF dual-hosted git repository. Amar3tto pushed a commit to branch release-2.78 in repository https://gitbox.apache.org/repos/asf/beam.git
commit fe2ba42066a866aee7a1bdd0c9292d1ce49f4697 Merge: 6e7ce70ffed 3b59922ae5f Author: Vitaly Terentyev <[email protected]> AuthorDate: Thu Oct 29 12:05:39 2026 +0400 Merge pull request #40877 from chamikaramj/release-2.78 Updates Delta CDC read to fail when schemas... (#40868) .../beam_PostCommit_Java_Delta_IO_Dataflow.json | 2 +- .../beam_PreCommit_Java_Delta_IO_Direct.json | 2 +- .../beam/sdk/io/delta/CreateCDCReadTasksDoFn.java | 44 ++++- .../java/org/apache/beam/sdk/io/delta/DeltaIO.java | 39 +++- .../apache/beam/sdk/io/delta/DeltaSchemaUtils.java | 188 ++++++++++++++++++ .../org/apache/beam/sdk/io/delta/DeltaIOTest.java | 206 +++++++++++++++++++ .../beam/sdk/io/delta/DeltaSchemaUtilsTest.java | 220 +++++++++++++++++++++ .../beam/sdk/io/delta/DeltaWriteTestUtils.java | 125 ++++++++++++ 8 files changed, 814 insertions(+), 12 deletions(-)
