This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 1ec9c16cc05 [hotfix] Remove unnecessary StateBackend
1ec9c16cc05 is described below
commit 1ec9c16cc058eec007a8c5f65fbbbe25804ad276
Author: beliefer <[email protected]>
AuthorDate: Wed May 7 17:08:12 2025 +0800
[hotfix] Remove unnecessary StateBackend
---
.../flink/state/changelog/AbstractChangelogStateBackend.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git
a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java
b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java
index d114794651c..94d9dc610f0 100644
---
a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java
+++
b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java
@@ -44,12 +44,11 @@ import java.util.Objects;
import java.util.stream.Collectors;
/**
- * An abstract base implementation of the {@link StateBackend} interface whose
subclasses use
- * delegatedStateBackend and State changes to restore.
+ * An abstract base implementation of the {@link DelegatingStateBackend}
interface whose subclasses
+ * use delegatedStateBackend and State changes to restore.
*/
@Internal
-public abstract class AbstractChangelogStateBackend
- implements DelegatingStateBackend, StateBackend {
+public abstract class AbstractChangelogStateBackend implements
DelegatingStateBackend {
private static final long serialVersionUID = 1000L;