From c3273c1296155c626c0718e855e4b94690ea806a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Bobowski?= <145468486+sfc-gh-mbobowski@users.noreply.github.com> Date: Wed, 20 Nov 2024 10:05:22 +0100 Subject: [PATCH] SNOW-1761519 Fix empty arrays in Iceberg ingestion (#1003) --- .../connector/streaming/iceberg/sql/ComplexJsonRecord.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/com/snowflake/kafka/connector/streaming/iceberg/sql/ComplexJsonRecord.java b/src/test/java/com/snowflake/kafka/connector/streaming/iceberg/sql/ComplexJsonRecord.java index 92adbb66d..6df73ded1 100644 --- a/src/test/java/com/snowflake/kafka/connector/streaming/iceberg/sql/ComplexJsonRecord.java +++ b/src/test/java/com/snowflake/kafka/connector/streaming/iceberg/sql/ComplexJsonRecord.java @@ -30,7 +30,7 @@ public class ComplexJsonRecord { true, ImmutableList.of(1, 2, 3), ImmutableList.of("a", "b", "c"), - ImmutableList.of(true), // FIXME: SNOW-1761519 here should be empty array + ImmutableList.of(), null, ImmutableList.of(ImmutableList.of(7, 8, 9), ImmutableList.of(10, 11, 12)), PrimitiveJsonRecord.primitiveJsonRecordValueExample, @@ -48,7 +48,7 @@ public class ComplexJsonRecord { + " \"approval\": true," + " \"array1\": [1, 2, 3]," + " \"array2\": [\"a\", \"b\", \"c\"]," - + " \"array3\": [true]," // FIXME: SNOW-1761519 here should be empty array + + " \"array3\": []," + " \"array4\": null," + " \"array5\": [[7, 8, 9], [10, 11, 12]]," + " \"nestedRecord\": "