diff --git a/fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java b/fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java index 6cce1c238c..3e14c179e5 100644 --- a/fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java +++ b/fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java @@ -141,8 +141,8 @@ public static PeriodicSnapshotManager create( } public void start() { - // disable periodic snapshot when periodicMaterializeDelay is negative - if (!started && periodicSnapshotDelay >= 0) { + // disable periodic snapshot when periodicMaterializeDelay is not positive + if (!started && periodicSnapshotDelay > 0) { started = true; diff --git a/website/docs/quickstart/flink.md b/website/docs/quickstart/flink.md index d56effa6c7..b05a59489b 100644 --- a/website/docs/quickstart/flink.md +++ b/website/docs/quickstart/flink.md @@ -54,6 +54,7 @@ services: tablet-server.host: tablet-server data.dir: /tmp/fluss/data remote.data.dir: /tmp/fluss/remote-data + kv.snapshot.interval: 0s lakehouse.storage: paimon paimon.catalog.metastore: filesystem paimon.catalog.warehouse: /tmp/paimon