update

zhangstar333 · May 22, 2024 · 2a99966 · 2a99966
1 parent abaa73a
commit 2a99966
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);