diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-17 16:11:57 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-17 16:11:57 -0700 |
| commit | f90d2c93c9e34997a8e76aeefb438ec06b1cd093 (patch) | |
| tree | 3966daffbb7b2633906f883e3047511772a4fdcf /other/java/hdfs2 | |
| parent | 3abd74b1d7d1685ca4ddcd741ddf3ac0585b848a (diff) | |
| download | seaweedfs-f90d2c93c9e34997a8e76aeefb438ec06b1cd093.tar.xz seaweedfs-f90d2c93c9e34997a8e76aeefb438ec06b1cd093.zip | |
1.3.9 remove logs
Diffstat (limited to 'other/java/hdfs2')
| -rw-r--r-- | other/java/hdfs2/dependency-reduced-pom.xml | 2 | ||||
| -rw-r--r-- | other/java/hdfs2/pom.xml | 2 | ||||
| -rw-r--r-- | other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java | 4 |
3 files changed, 4 insertions, 4 deletions
diff --git a/other/java/hdfs2/dependency-reduced-pom.xml b/other/java/hdfs2/dependency-reduced-pom.xml index 287200fd1..62cd798b4 100644 --- a/other/java/hdfs2/dependency-reduced-pom.xml +++ b/other/java/hdfs2/dependency-reduced-pom.xml @@ -127,7 +127,7 @@ </snapshotRepository>
</distributionManagement>
<properties>
- <seaweedfs.client.version>1.3.8</seaweedfs.client.version>
+ <seaweedfs.client.version>1.3.9</seaweedfs.client.version>
<hadoop.version>2.9.2</hadoop.version>
</properties>
</project>
diff --git a/other/java/hdfs2/pom.xml b/other/java/hdfs2/pom.xml index 150e37e41..1f4e7aebc 100644 --- a/other/java/hdfs2/pom.xml +++ b/other/java/hdfs2/pom.xml @@ -5,7 +5,7 @@ <modelVersion>4.0.0</modelVersion> <properties> - <seaweedfs.client.version>1.3.8</seaweedfs.client.version> + <seaweedfs.client.version>1.3.9</seaweedfs.client.version> <hadoop.version>2.9.2</hadoop.version> </properties> diff --git a/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java b/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java index c1e7b593d..46de0c443 100644 --- a/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java +++ b/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java @@ -184,9 +184,9 @@ public class SeaweedOutputStream extends OutputStream { waitForTaskToComplete(); } final Future<Void> job = completionService.submit(() -> { - System.out.println(path + " is going to save [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); + // System.out.println(path + " is going to save [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); SeaweedWrite.writeData(entry, replication, filerGrpcClient, writePosition, bufferToWrite.array(), bufferToWrite.position(), bufferToWrite.limit()); - System.out.println(path + " saved [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); + // System.out.println(path + " saved [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); bufferToWrite.clear(); ByteBufferPool.release(bufferToWrite); return null; |