Skip to content

Commit 703df58

Browse files
committed
fix(hdrs): Correct append operation
1 parent 9e10a66 commit 703df58

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/store/hadoop/hdrs.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,7 @@ impl HdfsDelegator for HdrsClient {
6666
let client = &self.inner.client;
6767
let mut file = client
6868
.open_file()
69-
.create(true)
70-
.write(true)
69+
.append(true)
7170
.open(path.as_str())?;
7271
file.write_all(&data)?;
7372
file.flush()?;

0 commit comments

Comments
 (0)