From 8e5369cf81d4ad98dbb57bf645a6fed5a8150c4b Mon Sep 17 00:00:00 2001 From: AlexYue Date: Mon, 22 Apr 2024 19:42:37 +0800 Subject: [PATCH] n [fix](HDFS) Correctly set hdfs cache allocator's offset (#33960) --- be/src/io/fs/hdfs_file_writer.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/io/fs/hdfs_file_writer.cpp b/be/src/io/fs/hdfs_file_writer.cpp index b47e4c3f2d2ebe..6f9105a89e7b94 100644 --- a/be/src/io/fs/hdfs_file_writer.cpp +++ b/be/src/io/fs/hdfs_file_writer.cpp @@ -226,6 +226,7 @@ Status HdfsFileWriter::_append(std::string_view content) { } size_t append_size = _batch_buffer.append(content); content.remove_prefix(append_size); + _bytes_appended += append_size; if (_batch_buffer.full()) { RETURN_IF_ERROR(_flush_buffer()); } @@ -240,7 +241,6 @@ Status HdfsFileWriter::appendv(const Slice* data, size_t data_cnt) { for (size_t i = 0; i < data_cnt; i++) { RETURN_IF_ERROR(_append({data[i].get_data(), data[i].get_size()})); - _bytes_appended += data[i].get_size(); } return Status::OK(); }