diff --git a/be/src/vec/runtime/vdata_stream_recvr.h b/be/src/vec/runtime/vdata_stream_recvr.h
index e55969d1f277ae..f82852141a4a04 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);
 
-    void add_block(Block* block, int sender_id, bool use_move);
+    int64_t add_block(Block* block, int sender_id, bool use_move);
 
     bool sender_queue_empty(int sender_id);