Search before asking
Fluss version
main (development)
Please describe the bug 🐞
When I use Flink to read a log table, I found the following error log. It's unnecessary to release kv snapshot lease for log table.
2026-02-26 10:27:57,938 [SourceCoordinator-Source: fluss_test_lake_table_zjk_log[1]] ERROR org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator [] - Failed to release kv snapshot lease. These snapshot need to re-enqueue
java.util.concurrent.ExecutionException: org.apache.fluss.exception.UnsupportedVersionException: The server does not support RELEASE_KV_SNAPSHOT_LEASE(1057)
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?]
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2005) ~[?:?]
at org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.notifyCheckpointComplete(FlinkSourceEnumerator.java:1055) ~[fluss-ali-alake-vvr-11-0.9-SNAPSHOT.jar:0.9-SNAPSHOT]
at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$notifyCheckpointComplete$8(SourceCoordinator.java:476) ~[flink-dist-1.20-vvr-11.4.0-jdk11-SNAPSHOT.jar:1.20-vvr-11.4.0-jdk11-SNAPSHOT]
at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$10(SourceCoordinator.java:560) ~[flink-dist-1.20-vvr-11.4.0-jdk11-SNAPSHOT.jar:1.20-vvr-11.4.0-jdk11-SNAPSHOT]
at org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40) [flink-dist-1.20-vvr-11.4.0-jdk11-SNAPSHOT.jar:1.20-vvr-11.4.0-jdk11-SNAPSHOT]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:991) [?:?]
Caused by: org.apache.fluss.exception.UnsupportedVersionException: The server does not support RELEASE_KV_SNAPSHOT_LEASE(1057)
Solution
No response
Are you willing to submit a PR?
Search before asking
Fluss version
main (development)
Please describe the bug 🐞
When I use Flink to read a log table, I found the following error log. It's unnecessary to release kv snapshot lease for log table.
Solution
No response
Are you willing to submit a PR?