This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5790d23624 [fix](transfer_thread) fix the loss of notification.
(#12988)
5790d23624 is described below
commit 5790d236249cde97c1ed0621279c699649c68553
Author: Xiaocc <[email protected]>
AuthorDate: Tue Sep 27 08:44:02 2022 +0800
[fix](transfer_thread) fix the loss of notification. (#12988)
---
be/src/vec/exec/volap_scan_node.cpp | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/be/src/vec/exec/volap_scan_node.cpp
b/be/src/vec/exec/volap_scan_node.cpp
index ebe6ab90cd..e7a48fa3ee 100644
--- a/be/src/vec/exec/volap_scan_node.cpp
+++ b/be/src/vec/exec/volap_scan_node.cpp
@@ -376,7 +376,10 @@ void VOlapScanNode::transfer_thread(RuntimeState* state) {
}
VLOG_CRITICAL << "TransferThread finish.";
- _transfer_done = true;
+ {
+ std::unique_lock<std::mutex> l(_blocks_lock);
+ _transfer_done = true;
+ }
_block_added_cv.notify_all();
{
std::unique_lock<std::mutex> l(_scan_blocks_lock);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
