Skip to content

[hotfix][flink] Fix release kv snapshot lease for log table#2719

Merged
swuferhong merged 1 commit intoapache:mainfrom
LiebingYu:fix-enumerator
Feb 26, 2026
Merged

[hotfix][flink] Fix release kv snapshot lease for log table#2719
swuferhong merged 1 commit intoapache:mainfrom
LiebingYu:fix-enumerator

Conversation

@LiebingYu
Copy link
Contributor

@LiebingYu LiebingYu commented Feb 26, 2026

Purpose

Linked issue: close #2738

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)

Brief change log

Tests

API and Format

Documentation

Copy link
Contributor

@swuferhong swuferhong left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM+1 Waiting CI.

@swuferhong swuferhong merged commit 4e54416 into apache:main Feb 26, 2026
6 checks passed
LiebingYu added a commit to LiebingYu/fluss that referenced this pull request Feb 26, 2026
swuferhong pushed a commit that referenced this pull request Feb 26, 2026
loserwang1024 pushed a commit to loserwang1024/fluss that referenced this pull request Feb 27, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Fix release kv snapshot lease for log table

3 participants