Test update for behavioural change caused by apache#11131

pvary · Dec 4, 2024 · cf103c2 · cf103c2
1 parent 997304c
commit cf103c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java b/...20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java
@@ -337,8 +337,8 @@ void testV2Table() throws Exception {
 
     runAndWaitForSuccess(infra.env(), infra.source(), infra.sink());
 
-    // One equality delete remains which could be relevant if there are other files in the table
-    assertFileNum(table, 1, 1);
+    // After #11131 we don't remove the delete files
+    assertFileNum(table, 1, 3);
 
     SimpleDataUtil.assertTableRecords(table, ImmutableList.of(createRecord(1, "c")));