From c5335f633bc0509c3f1cb8cfff23c01b1e5c4797 Mon Sep 17 00:00:00 2001 From: Jingsong Date: Mon, 1 Apr 2024 16:40:42 +0800 Subject: [PATCH] fix --- .../snapshot/ContinuousFromTimestampStartingScannerTest.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/paimon-core/src/test/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScannerTest.java b/paimon-core/src/test/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScannerTest.java index 4223e0c01a49..51c2c10e7260 100644 --- a/paimon-core/src/test/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScannerTest.java +++ b/paimon-core/src/test/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScannerTest.java @@ -116,6 +116,8 @@ public void testScanFromChangelog() throws Exception { Options options = new Options(); options.set(CoreOptions.SNAPSHOT_NUM_RETAINED_MAX, 2); options.set(CoreOptions.SNAPSHOT_NUM_RETAINED_MIN, 1); + options.set(CoreOptions.CHANGELOG_NUM_RETAINED_MAX, 20); + options.set(CoreOptions.CHANGELOG_NUM_RETAINED_MIN, 10); options.set(CoreOptions.CHANGELOG_PRODUCER, CoreOptions.ChangelogProducer.INPUT); FileStoreTable table = createFileStoreTable(