You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ta...@apache.org on 2025/05/12 09:10:30 UTC

(flink) branch master updated: [hotfix] Remove unnecessary StateBackend

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 <be...@163.com>
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;