[Enhancement] fix compilable issue in UnmodifiableCollectionsSerializer

fe/fe-core/src/main/java/org/apache/iceberg/MetadataParser.java

@@ -20,6 +20,7 @@
 import com.starrocks.connector.metadata.MetadataCollectJob;
 import com.starrocks.connector.share.iceberg.CommonMetadataBean;
 import com.starrocks.connector.share.iceberg.IcebergMetricsBean;
+import com.starrocks.connector.share.iceberg.UnmodifiableCollectionsSerializer;
 import com.starrocks.qe.ConnectContext;
 import com.starrocks.qe.scheduler.Coordinator;
 import com.starrocks.rpc.ConfigurableSerDesFactory;

java-extensions/hadoop-ext/pom.xml

@@ -44,6 +44,12 @@
             <version>${iceberg.version}</version>
             <scope>provided</scope>
         </dependency>
+
+        <dependency>
+            <groupId>com.esotericsoftware</groupId>
+            <artifactId>kryo-shaded</artifactId>
+            <version>4.0.2</version>
+        </dependency>
     </dependencies>
 
     <build>

java-extensions/hadoop-ext/src/main/java/com/starrocks/connector/share/iceberg/JavaImmutableMapSerializer.java

@@ -0,0 +1,66 @@
+package com.starrocks.connector.share.iceberg;
+
+import com.esotericsoftware.kryo.Kryo;
+import com.esotericsoftware.kryo.Serializer;
+import com.esotericsoftware.kryo.io.Input;
+import com.esotericsoftware.kryo.io.Output;
+import java.io.Serializable;
+import java.util.Map;
+
+@SuppressWarnings("rawtypes")
+public class JavaImmutableMapSerializer extends Serializer<Map<?, ?>> {
+
+    @Override
+    public void write(Kryo kryo, Output output, Map<?, ?> map) {
+        ImmSerMapEntry[] entries = map
+                .entrySet()
+                .stream()
+                .map(ImmSerMapEntry::new)
+                .toArray(ImmSerMapEntry[]::new);
+
+        kryo.writeObject(output, new ImmSerMap(entries));
+    }
+
+    @Override
+    public Map<?, ?> read(Kryo kryo, Input input, Class<Map<?, ?>> type) {
+        return Map.ofEntries(kryo.readObject(input, ImmSerMap.class).getEntries());
+    }
+
+
+    private static class ImmSerMap implements Serializable {
+
+        private final ImmSerMapEntry<?, ?>[] array;
+
+        private ImmSerMap(ImmSerMapEntry[] array) {
+            this.array = array;
+        }
+
+        private Map.Entry[] getEntries() {
+            return array;
+        }
+    }
+
+    private static class ImmSerMapEntry<K, V> implements Map.Entry<K, V>, Serializable {
+
+        private final Object[] entry;
+
+        private ImmSerMapEntry(Map.Entry<K, V> entry) {
+            this.entry = new Object[] { entry.getKey(), entry.getValue() };
+        }
+
+        @Override
+        public K getKey() {
+            return (K) entry[0];
+        }
+
+        @Override
+        public V getValue() {
+            return (V) entry[1];
+        }
+
+        @Override
+        public V setValue(V value) {
+            throw new UnsupportedOperationException();
+        }
+    }
+}

fe/fe-core/src/main/java/org/apache/iceberg/UnmodifiableCollectionsSerializer.java → java-extensions/hadoop-ext/src/main/java/com/starrocks/connector/share/iceberg/UnmodifiableCollectionsSerializer.java

@@ -11,7 +11,7 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-package org.apache.iceberg;
+package com.starrocks.connector.share.iceberg;
 
 import com.esotericsoftware.kryo.Kryo;
 import com.esotericsoftware.kryo.Serializer;

java-extensions/iceberg-metadata-reader/pom.xml

@@ -63,24 +63,6 @@
             </exclusions>
         </dependency>
 
-        <dependency>
-            <groupId>com.esotericsoftware</groupId>
-            <artifactId>kryo-shaded</artifactId>
-            <version>4.0.2</version>
-        </dependency>
-
-        <dependency>
-            <groupId>de.javakaffee</groupId>
-            <artifactId>kryo-serializers</artifactId>
-            <version>0.45</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>com.esotericsoftware</groupId>
-                    <artifactId>kryo</artifactId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-
         <dependency>
             <groupId>commons-lang</groupId>
             <artifactId>commons-lang</artifactId>

java-extensions/iceberg-metadata-reader/src/main/java/com/starrocks/connector/iceberg/IcebergMetadataScanner.java

@@ -19,8 +19,9 @@
 import com.google.common.collect.ImmutableList;
 import com.starrocks.connector.share.iceberg.CommonMetadataBean;
 import com.starrocks.connector.share.iceberg.IcebergMetricsBean;
+import com.starrocks.connector.share.iceberg.JavaImmutableMapSerializer;
+import com.starrocks.connector.share.iceberg.UnmodifiableCollectionsSerializer;
 import com.starrocks.jni.connector.ColumnValue;
-import de.javakaffee.kryoserializers.UnmodifiableCollectionsSerializer;
 import org.apache.iceberg.ContentFile;
 import org.apache.iceberg.ManifestContent;
 import org.apache.iceberg.ManifestFile;
@@ -165,6 +166,8 @@ private void initSerializer() {
         this.kryo = new Kryo();
         this.kryo.register(CommonMetadataBean.class);
         this.kryo.register(IcebergMetricsBean.class);
+        this.kryo.register(Map.of().getClass(), new JavaImmutableMapSerializer());
+        this.kryo.register(Map.of(1, 1).getClass(), new JavaImmutableMapSerializer());
         UnmodifiableCollectionsSerializer.registerSerializers(kryo);
         this.stream = new ByteArrayOutputStream();
         this.output = new Output(stream);