Use RecordWrapper

memiiso · Oct 5, 2024 · 421960d · 421960d
1 parent 8fc3705
commit 421960d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/test/java/io/debezium/server/iceberg/tableoperator/UnpartitionedDeltaWriterTest.java b/.../src/test/java/io/debezium/server/iceberg/tableoperator/UnpartitionedDeltaWriterTest.java
@@ -22,7 +22,7 @@ public void testUnpartitionedDeltaWriter() throws IOException {
     row.setField("id2", "123");
     row.setField("__op", "u");
 
-    writer.write(row);
+    writer.write(new RecordWrapper(row, Operation.UPDATE));
     WriteResult result = writer.complete();
 
     // in upsert mode, each write is a delete + append, so we'll have 1 data file and 1 delete file