diff options
| author | limd <limd@sugon.com> | 2020-09-26 01:38:48 +0800 |
|---|---|---|
| committer | limd <limd@sugon.com> | 2020-09-26 01:38:48 +0800 |
| commit | 95bfec4931260eb7b73c97861c4929623c8321d6 (patch) | |
| tree | 34a2c71a62a637571ad67147315c1270cbca90c5 /other/java | |
| parent | 402aef8f301403f46b702fbbb63d179caa2b72f3 (diff) | |
| download | seaweedfs-95bfec4931260eb7b73c97861c4929623c8321d6.tar.xz seaweedfs-95bfec4931260eb7b73c97861c4929623c8321d6.zip | |
hadoop: filesystem cannot create file
issues: https://github.com/chrislusf/seaweedfs/issues/1494
Diffstat (limited to 'other/java')
| -rw-r--r-- | other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java | 2 |
1 files changed, 2 insertions, 0 deletions
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 53185367a..2d9f3ccb9 100644 --- a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java +++ b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java @@ -202,6 +202,8 @@ public class SeaweedFileSystemStore { .clearGroupName() .addAllGroupName(Arrays.asList(userGroupInformation.getGroupNames())) ); + + filerClient.createEntry(getParentDirectory(path), entry.build()); } return new SeaweedOutputStream(filerGrpcClient, path, entry, writePosition, bufferSize, replication); |