diff --git a/be/src/vec/runtime/vdata_stream_recvr.cpp b/be/src/vec/runtime/vdata_stream_recvr.cpp
index fd9460fffffecf..22181bb174b190 100644
--- a/be/src/vec/runtime/vdata_stream_recvr.cpp
+++ b/be/src/vec/runtime/vdata_stream_recvr.cpp
@@ -432,7 +432,7 @@ Status VDataStreamRecvr::add_block(const PBlock& pblock, int sender_id, int be_n
     return Status::OK();
 }
 
-int64_t VDataStreamRecvr::add_block(Block* block, int sender_id, bool use_move) {
+void VDataStreamRecvr::add_block(Block* block, int sender_id, bool use_move) {
     int use_sender_id = _is_merging ? sender_id : 0;
     _sender_queues[use_sender_id]->add_block(block, use_move);
     _queue_total_rows[use_sender_id] = _queue_total_rows[use_sender_id] + block->rows();
diff --git a/be/src/vec/runtime/vdata_stream_recvr.h b/be/src/vec/runtime/vdata_stream_recvr.h
index f82852141a4a04..e55969d1f277ae 100644
--- a/be/src/vec/runtime/vdata_stream_recvr.h
+++ b/be/src/vec/runtime/vdata_stream_recvr.h
@@ -85,7 +85,7 @@ class VDataStreamRecvr : public HasTaskExecutionCtx {
     Status add_block(const PBlock& pblock, int sender_id, int be_number, int64_t packet_seq,
                      ::google::protobuf::Closure** done);
 
-    int64_t add_block(Block* block, int sender_id, bool use_move);
+    void add_block(Block* block, int sender_id, bool use_move);
 
     bool sender_queue_empty(int sender_id);