[hotfix] Remove inappropriate annotation in flink-statebackend-forst (

#26123)
apache · Feb 8, 2025 · f3fe66d · f3fe66d
1 parent 5a1ef84
commit f3fe66d
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 6 deletions.
diff --git a/...st/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java b/...st/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.state.forst.fs;
 
-import org.apache.flink.annotation.Experimental;
 import org.apache.flink.core.fs.ByteBufferReadable;
 import org.apache.flink.core.fs.FSDataInputStream;
 
@@ -35,7 +34,6 @@
  * <p>All methods in this class maybe used by ForSt, please start a discussion firstly if it has to
  * be modified.
  */
-@Experimental
 public class ByteBufferReadableFSDataInputStream extends FSDataInputStream {
 
     private final FSDataInputStream originalInputStream;

diff --git a/...t/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java b/...t/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.state.forst.fs;
 
-import org.apache.flink.annotation.Experimental;
 import org.apache.flink.core.fs.FSDataOutputStream;
 import org.apache.flink.core.memory.MemoryUtils;
 
@@ -32,7 +31,6 @@
  * <p>All methods in this class maybe used by ForSt, please start a discussion firstly if it has to
  * be modified.
  */
-@Experimental
 public class ByteBufferWritableFSDataOutputStream extends FSDataOutputStream {
 
     /** The unsafe handle for transparent memory copied (heap / off-heap). */

diff --git a/...tatebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java b/...tatebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.state.forst.fs;
 
-import org.apache.flink.annotation.Experimental;
 import org.apache.flink.core.fs.BlockLocation;
 import org.apache.flink.core.fs.FSDataInputStream;
 import org.apache.flink.core.fs.FSDataOutputStream;
@@ -60,7 +59,6 @@
  * <p>All methods in this class maybe used by ForSt, please start a discussion firstly if it has to
  * be modified.
  */
-@Experimental
 public class ForStFlinkFileSystem extends FileSystem {
 
     private static final Logger LOG = LoggerFactory.getLogger(ForStFlinkFileSystem.class);