fix bug that exchange receiver may hang forever (#2707)

pingcap · Aug 17, 2021 · 1e071f0 · 1e071f0
1 parent bb5ad27
commit 1e071f0
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/dbms/src/Flash/Mpp/ExchangeReceiver.cpp b/dbms/src/Flash/Mpp/ExchangeReceiver.cpp
@@ -34,7 +34,6 @@ void ExchangeReceiver::setUpConnection()
     {
         auto & meta = pb_exchange_receiver.encoded_task_meta(index);
         std::thread t(&ExchangeReceiver::ReadLoop, this, std::ref(meta), index);
-        live_connections++;
         workers.push_back(std::move(t));
     }
 }

diff --git a/dbms/src/Flash/Mpp/ExchangeReceiver.h b/dbms/src/Flash/Mpp/ExchangeReceiver.h
@@ -109,7 +109,7 @@ class ExchangeReceiver
           source_num(pb_exchange_receiver.encoded_task_meta_size()),
           task_meta(meta),
           max_buffer_size(max_buffer_size_),
-          live_connections(0),
+          live_connections(pb_exchange_receiver.encoded_task_meta_size()),
           state(NORMAL),
           log(&Logger::get("exchange_receiver"))
     {