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 3048d772ae Flink: Dynamic Sink: Fix serialization issues with schemas
larger than 2^16 bytes (#14880)
add 4bd1fb8632 Flink: DynamicSink: Report writer records/bytes send
metrics (#14878)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 1 +
.../flink/sink/dynamic/DynamicWriterMetrics.java | 31 +++++++++++++++++++---
.../flink/sink/dynamic/TestDynamicWriter.java | 2 +-
3 files changed, 30 insertions(+), 4 deletions(-)
