This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.0 by this push:
new 3f8aadc1e01 [hotfix] Remove inappropriate annotation in
`flink-statebackend-forst` (#26124)
3f8aadc1e01 is described below
commit 3f8aadc1e014fea8fe4f1b21417078233013c60f
Author: Zakelly <[email protected]>
AuthorDate: Sat Feb 8 19:12:59 2025 +0800
[hotfix] Remove inappropriate annotation in `flink-statebackend-forst`
(#26124)
---
.../flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java | 2 --
.../flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java | 2 --
.../main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java | 2 --
3 files changed, 6 deletions(-)
diff --git
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java
index 37dc5f22361..79d64bb78ba 100644
---
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java
+++
b/flink-state-backends/flink-statebackend-forst/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 @@ import java.util.concurrent.LinkedBlockingQueue;
* <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/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java
index aa7b975a02b..e6180503898 100644
---
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java
+++
b/flink-state-backends/flink-statebackend-forst/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 @@ import java.nio.ByteBuffer;
* <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/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java
index 045c3a81d4c..3966926397c 100644
---
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java
+++
b/flink-state-backends/flink-statebackend-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 @@ import java.util.List;
* <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);
