Skip to content

Commit 0d13ec9

Browse files
committed
fix
1 parent 6c63480 commit 0d13ec9

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/procedure/ExpireSnapshotsProcedureITCase.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,12 +72,12 @@ public void testExpireSnapshotsProcedure() throws Exception {
7272
+ "', retain_min => 3)");
7373
checkSnapshots(snapshotManager, 4, 6);
7474

75-
// older_than => timestamp of snapshot 6, expected snapshots (6)
75+
// older_than => timestamp of snapshot 6, expected snapshots (5, 6)
7676
sql(
7777
"CALL sys.expire_snapshots(`table` => 'default.word_count', older_than => '"
7878
+ ts6.toString()
7979
+ "')");
80-
checkSnapshots(snapshotManager, 6, 6);
80+
checkSnapshots(snapshotManager, 5, 6);
8181
}
8282

8383
@ParameterizedTest
@@ -157,7 +157,7 @@ public void testExpireSnapshotsAction(boolean forceStartFlinkJob) throws Excepti
157157
.run();
158158
checkSnapshots(snapshotManager, 4, 6);
159159

160-
// older_than => timestamp of snapshot 6, expected snapshots (6)
160+
// older_than => timestamp of snapshot 6, expected snapshots (5, 6)
161161
createAction(
162162
ExpireSnapshotsAction.class,
163163
"expire_snapshots",
@@ -173,7 +173,7 @@ public void testExpireSnapshotsAction(boolean forceStartFlinkJob) throws Excepti
173173
Boolean.toString(forceStartFlinkJob))
174174
.withStreamExecutionEnvironment(env)
175175
.run();
176-
checkSnapshots(snapshotManager, 6, 6);
176+
checkSnapshots(snapshotManager, 5, 6);
177177
}
178178

179179
@Test

0 commit comments

Comments
 (0)