fix

yuzelin · Jan 6, 2025 · 3be8256 · 3be8256
1 parent 39ae9c1
commit 3be8256
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkCatalogTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkCatalogTest.java
@@ -984,9 +984,12 @@ private static Stream<Map<String, String>> optionProvider(boolean isStreaming) {
                 options.put(SCAN_FILE_CREATION_TIME_MILLIS.key(), System.currentTimeMillis() + "");
             } else if (mode == CoreOptions.StartupMode.INCREMENTAL) {
                 options.put("incremental-between", "2,5");
+            } else if (mode == CoreOptions.StartupMode.INCREMENTAL_TO_AUTO_TAG) {
+                options.put("incremental-to", "2024-12-01");
             }
 
-            if (isStreaming && mode == CoreOptions.StartupMode.INCREMENTAL) {
+            if (isStreaming && mode == CoreOptions.StartupMode.INCREMENTAL
+                    || mode == CoreOptions.StartupMode.INCREMENTAL_TO_AUTO_TAG) {
                 continue;
             }
             allOptions.add(options);