aboutsummaryrefslogtreecommitdiff
path: root/other/java/hdfs2
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-10-25 15:32:43 -0700
committerChris Lu <chris.lu@gmail.com>2020-10-25 15:32:43 -0700
commitf375b93aefd8d7358df7ff5232d522a31bd15afb (patch)
tree63d4196b2c881fd808ec7cedf4414806b685dc21 /other/java/hdfs2
parent596d476e3d858d2cb0520231f1da44804e7f2be1 (diff)
downloadseaweedfs-f375b93aefd8d7358df7ff5232d522a31bd15afb.tar.xz
seaweedfs-f375b93aefd8d7358df7ff5232d522a31bd15afb.zip
renaming
Diffstat (limited to 'other/java/hdfs2')
-rw-r--r--other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java2
1 files changed, 1 insertions, 1 deletions
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 dbcae6423..26290c46c 100644
--- a/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java
+++ b/other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedOutputStream.java
@@ -185,7 +185,7 @@ public class SeaweedOutputStream extends OutputStream {
}
final Future<Void> job = completionService.submit(() -> {
// System.out.println(path + " is going to save [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")");
- SeaweedWrite.writeData(entry, replication, filerGrpcClient, writePosition, bufferToWrite.array(), bufferToWrite.position(), bufferToWrite.limit(), getParentDirectory(path));
+ SeaweedWrite.writeData(entry, replication, filerGrpcClient, writePosition, bufferToWrite.array(), bufferToWrite.position(), bufferToWrite.limit(), path.toUri().getPath());
// System.out.println(path + " saved [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")");
ByteBufferPool.release(bufferToWrite);
return null;