You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/10/18 02:27:48 UTC
[incubator-seatunnel] branch dev updated: [Feature][Connector-V2][File] Fix filesystem get error (#3117)
This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 7404c180d [Feature][Connector-V2][File] Fix filesystem get error (#3117)
7404c180d is described below
commit 7404c180de8b2bf2b43cbff866ac4a9a951e8bdb
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Tue Oct 18 10:27:43 2022 +0800
[Feature][Connector-V2][File] Fix filesystem get error (#3117)
---
.../connectors/seatunnel/file/sink/util/FileSystemUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/util/FileSystemUtils.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/util/FileSystemUtils.java
index 9354130bb..652f7e6ac 100644
--- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/util/FileSystemUtils.java
+++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/util/FileSystemUtils.java
@@ -25,9 +25,9 @@ import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
-import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
+import java.net.URI;
import java.util.ArrayList;
import java.util.List;
@@ -39,7 +39,7 @@ public class FileSystemUtils {
public static Configuration CONF;
public static FileSystem getFileSystem(@NonNull String path) throws IOException {
- FileSystem fileSystem = FileSystem.get(new File(path).toURI(), CONF);
+ FileSystem fileSystem = FileSystem.get(URI.create(path.replaceAll("\\\\", "/")), CONF);
fileSystem.setWriteChecksum(false);
return fileSystem;
}