diff --git a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java b/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java index 580734fa9186..d04908352510 100644 --- a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java +++ b/flink/v1.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")));