diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java index 4090cf6f..ea9b0d1c 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java +++ b/debezium-server-iceberg-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)