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

pingcap · Sep 16, 2021 · a5eec5f · a5eec5f
1 parent a1debcb
commit a5eec5f
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"))
     {