Upgrade to support Iceberg Variant

Author: sfc-gh-aixu

pom.xml

@@ -60,13 +60,13 @@
         <!--Compatible protobuf version https://github.com/confluentinc/common/blob/v7.7.0/pom.xml#L91 -->
         <protobuf.version>3.25.5</protobuf.version>
         <guava.version>33.4.0-jre</guava.version>
-        <iceberg.version>1.6.1</iceberg.version>
+        <iceberg.version>1.10.0</iceberg.version>
         <jackson.version>2.18.2</jackson.version>
         <commons-compress.version>1.27.1</commons-compress.version>
         <maven-surefire-plugin.version>3.5.2</maven-surefire-plugin.version>
         <snowflake-jdbc.version>3.26.1</snowflake-jdbc.version>
         <slf4j-api.version>2.0.17</slf4j-api.version>
-        <parquet.version>1.14.4</parquet.version>
+        <parquet.version>1.15.1</parquet.version>
         <commons-lang3.version>3.18.0</commons-lang3.version>
     </properties>
 

src/main/java/com/snowflake/kafka/connector/internal/streaming/schemaevolution/iceberg/IcebergColumnTypeMapper.java

@@ -62,6 +62,8 @@ String mapToColumnTypeFromIcebergSchema(Type apacheIcebergType) {
         return "ARRAY";
       case MAP:
         return "MAP";
+      case VARIANT:
+        return "VARIANT";
       default:
         throw SnowflakeErrors.ERROR_5025.getException(
             "Data type: " + apacheIcebergType.typeId().name());

src/test/java/com/snowflake/kafka/connector/streaming/iceberg/IcebergIngestionNoSchemaEvolutionIT.java

@@ -50,6 +50,7 @@ public class IcebergIngestionNoSchemaEvolutionIT extends IcebergIngestionIT {
           + "array3 ARRAY(BOOLEAN),"
           + "array4 ARRAY(LONG),"
           + "array5 ARRAY(ARRAY(LONG)),"
+          + "var VARIANT,"
           + "nestedRecord "
           + PRIMITIVE_JSON_RECORD_CONTENT_OBJECT_SCHEMA
           + ","