update IT make two tags snapshot all expire

jerry-024 · Jan 7, 2025 · d777508 · d777508
1 parent 30ef1ee
commit d777508
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java b/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
@@ -302,12 +302,14 @@ public void testTimeTravelReadWithSnapshotExpiration() throws Exception {
     @Test
     public void testIncrementBetweenReadWithSnapshotExpiration() throws Exception {
         String tableName = "T";
-        batchSql(String.format("INSERT INTO %s VALUES (1, 11, 111), (2, 22, 222)", tableName));
+        batchSql(String.format("INSERT INTO %s VALUES (1, 11, 111)", tableName));
 
         paimonTable(tableName).createTag("tag1", 1);
 
-        batchSql(String.format("INSERT INTO %s VALUES (3, 33, 333)", tableName));
+        batchSql(String.format("INSERT INTO %s VALUES (2, 22, 222)", tableName));
         paimonTable(tableName).createTag("tag2", 2);
+        batchSql(String.format("INSERT INTO %s VALUES (3, 33, 333)", tableName));
+        paimonTable(tableName).createTag("tag3", 3);
 
         // expire snapshot 1
         Map<String, String> expireOptions = new HashMap<>();
@@ -322,7 +324,7 @@ public void testIncrementBetweenReadWithSnapshotExpiration() throws Exception {
                                 String.format(
                                         "SELECT * FROM %s /*+ OPTIONS('incremental-between' = 'tag1,tag2', 'deletion-vectors.enabled' = 'true') */",
                                         tableName)))
-                .containsExactlyInAnyOrder(Row.of(3, 33, 333));
+                .containsExactlyInAnyOrder(Row.of(2, 22, 222));
     }
 
     @Test