From c15aa9d05fbf58ad0ced79b140e0eff5d4466ee3 Mon Sep 17 00:00:00 2001
From: rwilson-r7 <rwilson@rapid7.com>
Date: Wed, 20 Nov 2024 14:55:24 +0000
Subject: [PATCH] default to string to test

---
 .../main/java/io/tabular/iceberg/connect/data/SchemaUtils.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java b/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java
index 43c7944b..2fe01c19 100644
--- a/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java
+++ b/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java
@@ -322,7 +322,7 @@ private Type doInferIcebergType(Object value) {
       } else if (value instanceof List) {
         List<?> list = (List<?>) value;
         if (list.isEmpty()) {
-          return null;
+          return ListType.ofOptional(nextId(), StringType.get());
         }
         Optional<Type> elementType = inferIcebergType(list.get(0));
         return elementType.map(type -> ListType.ofOptional(nextId(), type)).orElse(null);