Skip to content

Fix release kv snapshot lease for log table #2738

@LiebingYu

Description

@LiebingYu

Search before asking

  • I searched in the issues and found nothing similar.

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?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

Type

No fields configured for Bug.

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions