Tamas Mate has uploaded this change for review. ( http://gerrit.cloudera.org:8080/18648
Change subject: IMPALA-11377: Handle concurrent Iceberg INSERT OVERWRITEs ...................................................................... IMPALA-11377: Handle concurrent Iceberg INSERT OVERWRITEs Iceberg now supports validations in the ReplacePartitions API, an initial snapshot id can be configured for the operation and Iceberg will validate at commit if there were any conflicting change while the ReplacePartitions was running. This commit utilizes this new functionality, the Coordinator sends the initial snapshot id to the Catalog, so the Catalog can validate the operation. Testing: - Added e2e tests. Change-Id: I812d19736c8e563541b038970786de7710b59f31 --- M be/src/service/client-request-state.cc M common/thrift/CatalogService.thrift M common/thrift/Query.thrift M fe/src/main/java/org/apache/impala/service/Frontend.java M fe/src/main/java/org/apache/impala/service/IcebergCatalogOpExecutor.java M tests/query_test/test_iceberg.py 6 files changed, 55 insertions(+), 3 deletions(-) git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/48/18648/1 -- To view, visit http://gerrit.cloudera.org:8080/18648 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: I812d19736c8e563541b038970786de7710b59f31 Gerrit-Change-Number: 18648 Gerrit-PatchSet: 1 Gerrit-Owner: Tamas Mate <[email protected]>
