fix comments

Signed-off-by: silverbullet233 <[email protected]>
StarRocks · Sep 18, 2024 · 3ca485f · 3ca485f
1 parent 5717597
commit 3ca485f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/exec/tablet_sink_index_channel.cpp b/be/src/exec/tablet_sink_index_channel.cpp
@@ -419,7 +419,7 @@ void NodeChannel::_reset_cur_chunk(Chunk* input) {
     int64_t before_consumed_bytes = CurrentThread::current().get_consumed_bytes();
     _cur_chunk = input->clone_empty_with_slot();
     int64_t after_consumed_bytes = CurrentThread::current().get_consumed_bytes();
-    _cur_chunk_mem_usage = after_consumed_bytes - before_consumed_bytes;
+    _cur_chunk_mem_usage += after_consumed_bytes - before_consumed_bytes;
 }
 
 void NodeChannel::_append_data_to_cur_chunk(const Chunk& src, const uint32_t* indexes, uint32_t from, uint32_t size) {