This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch release-2.66 in repository https://gitbox.apache.org/repos/asf/beam.git
commit d16b677d73a1a3a7f5c31ec3115a37b0b84e7107 Merge: 48c008be34d 579981e1e52 Author: Vitaly Terentyev <[email protected]> AuthorDate: Mon Jun 23 12:07:50 2025 +0400 IcebergIO Cherrypick #35341 (#35354) Cherrypick #35341 .github/trigger_files/beam_PostCommit_SQL.json | 2 +- .../sql/impl/parser/SqlCreateExternalTable.java | 5 +- .../sql/meta/provider/TableProvider.java | 2 +- .../sql/meta/provider/iceberg/IcebergCatalog.java | 6 +- .../provider/iceberg/IcebergTableProvider.java | 54 +++++++++++++++++- .../sql/meta/store/InMemoryMetaStore.java | 17 +++++- .../beam/sdk/extensions/sql/PubsubToIcebergIT.java | 29 ++++++---- .../meta/provider/iceberg/IcebergReadWriteIT.java | 64 ++++++++++++---------- .../provider/iceberg/IcebergTableProviderTest.java | 31 ----------- .../beam/sdk/io/iceberg/IcebergCatalogConfig.java | 30 ++++++++++ .../sdk/io/iceberg/IcebergTableCreateConfig.java | 8 +-- .../apache/beam/sdk/io/iceberg/PartitionUtils.java | 6 +- .../beam/sdk/io/iceberg/RecordWriterManager.java | 6 +- .../io/iceberg/TableAlreadyExistsException.java} | 11 ++-- 14 files changed, 170 insertions(+), 101 deletions(-)
