add time travel

apache · Nov 5, 2024 · 4ce761e · 4ce761e
1 parent 3794d95
commit 4ce761e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...on-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ObjectTableITCase.java b/...on-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ObjectTableITCase.java
@@ -69,5 +69,9 @@ public void testObjectTableRefresh() throws IOException {
         fileIO.deleteQuietly(new Path(objectLocation, "f0"));
         sql("CALL sys.refresh_object_table('default.T')");
         assertThat(sql("SELECT name, length FROM T")).containsExactlyInAnyOrder(Row.of("f1", 5L));
+
+        // time travel
+        assertThat(sql("SELECT name, length FROM T /*+ OPTIONS('scan.snapshot-id' = '1') */"))
+                .containsExactlyInAnyOrder(Row.of("f0", 5L));
     }
 }