This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 31fe60b903 Spark: Custom snapshot property from session configuration
(#14545)
add 31ce47b8b3 Flink: Set table properties/location on DynamicIcebergSink
table creation (#14578)
No new revisions were added by this update.
Summary of changes:
docs/docs/flink-writes.md | 1 +
.../flink/sink/dynamic/DynamicIcebergSink.java | 16 ++++++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 8 +++-
.../sink/dynamic/DynamicTableUpdateOperator.java | 11 ++++-
.../iceberg/flink/sink/dynamic/TableCreator.java | 17 ++++---
.../iceberg/flink/sink/dynamic/TableUpdater.java | 15 ++++--
.../dynamic/TestDynamicTableUpdateOperator.java | 6 ++-
.../flink/sink/dynamic/TestTableMetadataCache.java | 3 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++++++++++++++++-----
9 files changed, 98 insertions(+), 32 deletions(-)
copy core/src/main/java/org/apache/iceberg/view/ViewUtil.java =>
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableCreator.java
(65%)
