Fail deduplication if event key is null

memiiso · Jun 11, 2024 · f9e8060 · f9e8060
1 parent 3aa687b
commit f9e8060
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
@@ -151,7 +151,7 @@ public void testDeduplicateBatch() throws Exception {
     Assertions.assertEquals(1, dedups2.size());
     Assertions.assertEquals("u", dedups2.get(0).value().get("__op").asText("x"));
 
-    // @TODO deduplicate wth null key
+    // deduplicating wth null key should fail!
     IcebergChangeEvent e31 = new IcebergChangeEventBuilder()
         .destination("destination")
         .addField("id", 3)