diff options
| author | orthoxerox <orthoxerox@users.noreply.github.com> | 2025-05-09 19:09:13 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-05-09 09:09:13 -0700 |
| commit | d8cc26929434ff19f113a057d5c0d4092ee095ee (patch) | |
| tree | b0a3050b97631f6878481d0789d0c8083d2d99cf /other/java/hdfs3 | |
| parent | 848d1f7c34f4332d1bef0fe05679ee95dcb4f75b (diff) | |
| download | seaweedfs-d8cc26929434ff19f113a057d5c0d4092ee095ee.tar.xz seaweedfs-d8cc26929434ff19f113a057d5c0d4092ee095ee.zip | |
feature: added ssl support for HCFS (#6699) (#6775)
Diffstat (limited to 'other/java/hdfs3')
| -rw-r--r-- | other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java | 4 | ||||
| -rw-r--r-- | other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java | 5 |
2 files changed, 5 insertions, 4 deletions
diff --git a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java index b6ea4c3bb..58fcaf975 100644 --- a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java +++ b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java @@ -29,6 +29,7 @@ public class SeaweedFileSystem extends FileSystem { public static final String FS_SEAWEED_REPLICATION = "fs.seaweed.replication"; public static final String FS_SEAWEED_VOLUME_SERVER_ACCESS = "fs.seaweed.volume.server.access"; public static final int FS_SEAWEED_DEFAULT_BUFFER_SIZE = 4 * 1024 * 1024; + public static final String FS_SEAWEED_FILER_CN = "fs.seaweed.filer.cn"; private static final Logger LOG = LoggerFactory.getLogger(SeaweedFileSystem.class); @@ -63,8 +64,9 @@ public class SeaweedFileSystem extends FileSystem { setConf(conf); this.uri = uri; - seaweedFileSystemStore = new SeaweedFileSystemStore(host, port, grpcPort, conf); + String cn = conf.get(FS_SEAWEED_FILER_CN, ""); + seaweedFileSystemStore = new SeaweedFileSystemStore(host, port, grpcPort, cn, conf); } @Override diff --git a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java index a73dbeb74..f65c1961b 100644 --- a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java +++ b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java @@ -27,8 +27,8 @@ public class SeaweedFileSystemStore { private FilerClient filerClient; private Configuration conf; - public SeaweedFileSystemStore(String host, int port, int grpcPort, Configuration conf) { - filerClient = new FilerClient(host, port, grpcPort); + public SeaweedFileSystemStore(String host, int port, int grpcPort, String cn, Configuration conf) { + filerClient = new FilerClient(host, port, grpcPort, cn); this.conf = conf; String volumeServerAccessMode = this.conf.get(FS_SEAWEED_VOLUME_SERVER_ACCESS, "direct"); if (volumeServerAccessMode.equals("publicUrl")) { @@ -36,7 +36,6 @@ public class SeaweedFileSystemStore { } else if (volumeServerAccessMode.equals("filerProxy")) { filerClient.setAccessVolumeServerByFilerProxy(); } - } public void close() { |