(fluss) branch main updated: [hotfix] Fix compilation error: implement missing getMap method in IcebergArrayAsFlussArray (#2306)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new f90b33e83 [hotfix] Fix compilation error: implement missing getMap 
method in IcebergArrayAsFlussArray (#2306)
f90b33e83 is described below

commit f90b33e838eaae39b1945a62acd0c05a78576f07
Author: ForwardXu <forwar...@apache.org>
AuthorDate: Mon Jan 5 13:50:02 2026 +0800

    [hotfix] Fix compilation error: implement missing getMap method in 
IcebergArrayAsFlussArray (#2306)
---
 .../apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java  | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java
 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java
index 23aecefec..e8a4b1914 100644
--- 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java
+++ 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java
@@ -21,6 +21,7 @@ package org.apache.fluss.lake.iceberg.source;
 import org.apache.fluss.row.BinaryString;
 import org.apache.fluss.row.Decimal;
 import org.apache.fluss.row.InternalArray;
+import org.apache.fluss.row.InternalMap;
 import org.apache.fluss.row.InternalRow;
 import org.apache.fluss.row.TimestampLtz;
 import org.apache.fluss.row.TimestampNtz;
@@ -136,6 +137,11 @@ public class IcebergArrayAsFlussArray implements 
InternalArray {
         return nestedList == null ? null : new 
IcebergArrayAsFlussArray(nestedList);
     }
 
+    @Override
+    public InternalMap getMap(int pos) {
+        throw new UnsupportedOperationException();
+    }
+
     @Override
     public InternalRow getRow(int pos, int numFields) {
         throw new UnsupportedOperationException();