You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by le...@apache.org on 2026/04/05 19:43:01 UTC
(fluss-rust) branch main updated: fix: add missing write_array impl to IcebergBinaryRowWriter (#477)
This is an automated email from the ASF dual-hosted git repository.
leekei pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss-rust.git
The following commit(s) were added to refs/heads/main by this push:
new 1709ab5 fix: add missing write_array impl to IcebergBinaryRowWriter (#477)
1709ab5 is described below
commit 1709ab54b338f13118576984cb8a3a95b16f1cdd
Author: Keith Lee <le...@gmail.com>
AuthorDate: Sun Apr 5 20:42:55 2026 +0100
fix: add missing write_array impl to IcebergBinaryRowWriter (#477)
---
crates/fluss/src/row/binary/iceberg_binary_row_writer.rs | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/crates/fluss/src/row/binary/iceberg_binary_row_writer.rs b/crates/fluss/src/row/binary/iceberg_binary_row_writer.rs
index c87ae10..b0e8434 100644
--- a/crates/fluss/src/row/binary/iceberg_binary_row_writer.rs
+++ b/crates/fluss/src/row/binary/iceberg_binary_row_writer.rs
@@ -225,6 +225,10 @@ impl BinaryWriter for IcebergBinaryRowWriter {
self.write_raw(µs.to_le_bytes());
}
+ fn write_array(&mut self, _value: &[u8]) {
+ panic!("Iceberg key columns do not support array values");
+ }
+
fn complete(&mut self) {
// No finalization needed for Iceberg key encoding
}