fredia commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1756117771
##########
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##########
@@ -101,6 +142,12 @@ public boolean rename(Path src, Path dst) throws
IOException {
// The rename is not atomic for ForSt. Some FileSystems e.g. HDFS, OSS
does not allow a
// renaming if the target already exists. So, we delete the target
before attempting the
// rename.
+ if (isLocal(src) && isLocal(dst)) {
+ return localFS.rename(src, dst);
+ } else if (isLocal(src) || isLocal(dst)) {
+ throw new IOException("Rename between local and remote is not
supported.");
+ }
+
Review Comment:
Yes, fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
