default to string to test

rapid7 · Nov 20, 2024 · c15aa9d · c15aa9d
1 parent 3417141
commit c15aa9d
Showing 1 changed file with 1 addition and 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
@@ -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);