From 6c1c72b1f4168f5b91392d23ec8956ee95100d98 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Mon, 17 May 2021 23:18:37 -0700 Subject: java client 1.6.5 --- other/java/client/pom.xml | 2 +- other/java/client/pom.xml.deploy | 2 +- other/java/client/pom_debug.xml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) (limited to 'other/java/client') diff --git a/other/java/client/pom.xml b/other/java/client/pom.xml index f4e522a3e..a4231a1b8 100644 --- a/other/java/client/pom.xml +++ b/other/java/client/pom.xml @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.4 + 1.6.5 org.sonatype.oss diff --git a/other/java/client/pom.xml.deploy b/other/java/client/pom.xml.deploy index 9c8c4f45e..8fea51273 100644 --- a/other/java/client/pom.xml.deploy +++ b/other/java/client/pom.xml.deploy @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.4 + 1.6.5 org.sonatype.oss diff --git a/other/java/client/pom_debug.xml b/other/java/client/pom_debug.xml index 12ea860c2..235af9526 100644 --- a/other/java/client/pom_debug.xml +++ b/other/java/client/pom_debug.xml @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.4 + 1.6.5 org.sonatype.oss -- cgit v1.2.3 From 2d237f7b5091625a9e8e30cac12cb09a2e73d94b Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Fri, 21 May 2021 01:43:25 -0700 Subject: Java client: fix passing replication value --- .../java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'other/java/client') diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java index ba298a713..3bec05796 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java @@ -39,7 +39,7 @@ public class SeaweedOutputStream extends OutputStream { } public SeaweedOutputStream(FilerClient filerClient, final String fullpath, final String replication) { - this(filerClient, fullpath, null, 0, 8 * 1024 * 1024, "000"); + this(filerClient, fullpath, null, 0, 8 * 1024 * 1024, replication); } public SeaweedOutputStream(FilerClient filerClient, final String path, FilerProto.Entry.Builder entry, -- cgit v1.2.3 From 4d0b894d37870351052c343f41dca18acfd54194 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Fri, 21 May 2021 01:49:25 -0700 Subject: Java Client: throw exception when assign fails --- other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'other/java/client') diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java index f8c0c76b6..75d2a0e7e 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java @@ -1,5 +1,6 @@ package seaweedfs.client; +import com.google.common.base.Strings; import com.google.protobuf.ByteString; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; @@ -50,6 +51,11 @@ public class SeaweedWrite { .setTtlSec(0) .setPath(path) .build()); + + if (!Strings.isNullOrEmpty(response.getError())) { + throw new IOException(response.getError()); + } + String fileId = response.getFileId(); String auth = response.getAuth(); -- cgit v1.2.3 From 085a61cb8fdfc5d3f80de2768f5fd3081b873d64 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Fri, 21 May 2021 01:50:20 -0700 Subject: minor --- other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'other/java/client') diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java index 75d2a0e7e..3f9d79b99 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java @@ -46,7 +46,7 @@ public class SeaweedWrite { FilerProto.AssignVolumeResponse response = filerClient.getBlockingStub().assignVolume( FilerProto.AssignVolumeRequest.newBuilder() .setCollection(filerClient.getCollection()) - .setReplication(replication == null ? filerClient.getReplication() : replication) + .setReplication(Strings.isNullOrEmpty(replication) ? filerClient.getReplication() : replication) .setDataCenter("") .setTtlSec(0) .setPath(path) -- cgit v1.2.3 From 2d85ffe7c53c214dd7e9dac3f39bead8c5b51e87 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 23 May 2021 00:51:02 -0700 Subject: java 1.6.6 --- other/java/client/pom.xml | 2 +- other/java/client/pom.xml.deploy | 2 +- other/java/client/pom_debug.xml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) (limited to 'other/java/client') diff --git a/other/java/client/pom.xml b/other/java/client/pom.xml index a4231a1b8..d2c91b121 100644 --- a/other/java/client/pom.xml +++ b/other/java/client/pom.xml @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.5 + 1.6.6 org.sonatype.oss diff --git a/other/java/client/pom.xml.deploy b/other/java/client/pom.xml.deploy index 8fea51273..7910e2491 100644 --- a/other/java/client/pom.xml.deploy +++ b/other/java/client/pom.xml.deploy @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.5 + 1.6.6 org.sonatype.oss diff --git a/other/java/client/pom_debug.xml b/other/java/client/pom_debug.xml index 235af9526..c3cf904c0 100644 --- a/other/java/client/pom_debug.xml +++ b/other/java/client/pom_debug.xml @@ -5,7 +5,7 @@ com.github.chrislusf seaweedfs-client - 1.6.5 + 1.6.6 org.sonatype.oss -- cgit v1.2.3