From 0c9c1ff26c572134b0c80ff350b3def4a66b94b1 Mon Sep 17 00:00:00 2001 From: Ti Chi Robot Date: Tue, 16 Nov 2021 19:35:07 +0800 Subject: [PATCH] receiver buffer size should > max(source_num,max_streams) (#3445) (#3446) --- dbms/src/Flash/Mpp/ExchangeReceiver.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbms/src/Flash/Mpp/ExchangeReceiver.cpp b/dbms/src/Flash/Mpp/ExchangeReceiver.cpp index dd3fb393796..7a01783a66f 100644 --- a/dbms/src/Flash/Mpp/ExchangeReceiver.cpp +++ b/dbms/src/Flash/Mpp/ExchangeReceiver.cpp @@ -18,7 +18,7 @@ ExchangeReceiverBase::ExchangeReceiverBase( , source_num(pb_exchange_receiver.encoded_task_meta_size()) , task_meta(meta) , max_streams(max_streams_) - , max_buffer_size(max_streams_ * 2) + , max_buffer_size(std::max(source_num, max_streams_) * 2) , res_buffer(max_buffer_size) , live_connections(pb_exchange_receiver.encoded_task_meta_size()) , state(ExchangeReceiverState::NORMAL)