resolve java jar dependencies

3 files changed, 39 insertions, 9 deletions

diff --git a/other/java/hdfs/pom.xml b/other/java/hdfs/pom.xml
index e668e1266..963d3fc17 100644
--- a/other/java/hdfs/pom.xml
+++ b/other/java/hdfs/pom.xml
@@ -5,7 +5,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <groupId>seaweedfs</groupId>
-    <artifactId>hadoop-client</artifactId>
+    <artifactId>seaweedfs-hadoop-client</artifactId>
     <version>1.0-SNAPSHOT</version>
     <build>
         <plugins>
@@ -17,6 +17,35 @@
                     <target>7</target>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.2.1</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <transformers>
+                                <transformer
+                                        implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                            </transformers>
+                            <relocations>
+                                <relocation>
+                                    <pattern>com.google</pattern>
+                                    <shadedPattern>shaded.com.google</shadedPattern>
+                                </relocation>
+                                <relocation>
+                                    <pattern>io.grpc.internal</pattern>
+                                    <shadedPattern>shaded.io.grpc.internal</shadedPattern>
+                                </relocation>
+                            </relocations>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
 
@@ -32,7 +61,7 @@
         </dependency>
         <dependency>
             <groupId>seaweedfs</groupId>
-            <artifactId>client</artifactId>
+            <artifactId>seaweedfs-client</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
         <dependency>
diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
index 5599c5683..83a4938f5 100644
--- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
+++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
@@ -18,8 +18,8 @@ import java.net.URI;
 public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
 
     public static final int FS_SEAWEED_DEFAULT_PORT = 8333;
-    public static final String FS_SEAWEED_HOST = "fs.seaweed.host";
-    public static final String FS_SEAWEED_HOST_PORT = "fs.seaweed.host.port";
+    public static final String FS_SEAWEED_FILER_HOST = "fs.seaweed.filer.host";
+    public static final String FS_SEAWEED_FILER_PORT = "fs.seaweed.filer.port";
 
     private URI uri;
     private Path workingDirectory = new Path("/");
@@ -30,7 +30,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
     }
 
     public String getScheme() {
-        return "seaweed";
+        return "seaweedfs";
     }
 
     @Override
@@ -39,16 +39,16 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
 
         // get host information from uri (overrides info in conf)
         String host = uri.getHost();
-        host = (host == null) ? conf.get(FS_SEAWEED_HOST, null) : host;
+        host = (host == null) ? conf.get(FS_SEAWEED_FILER_HOST, "localhost") : host;
         if (host == null) {
             throw new IOException("Invalid host specified");
         }
-        conf.set(FS_SEAWEED_HOST, host);
+        conf.set(FS_SEAWEED_FILER_HOST, host);
 
         // get port information from uri, (overrides info in conf)
         int port = uri.getPort();
         port = (port == -1) ? FS_SEAWEED_DEFAULT_PORT : port;
-        conf.setInt(FS_SEAWEED_HOST_PORT, port);
+        conf.setInt(FS_SEAWEED_FILER_PORT, port);
 
         setConf(conf);
         this.uri = uri;
diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
index d890762a0..0ab17a2b5 100644
--- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
+++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
@@ -22,7 +22,8 @@ public class SeaweedFileSystemStore {
     private FilerGrpcClient filerGrpcClient;
 
     public SeaweedFileSystemStore(String host, int port) {
-        filerGrpcClient = new FilerGrpcClient(host, port);
+        int grpcPort = 10000 + port;
+        filerGrpcClient = new FilerGrpcClient(host, grpcPort);
     }
 
     public boolean createDirectory(final Path path, UserGroupInformation currentUser,