This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.1-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.1-lts by this push:
new fd0f755b88 [fix](transfer_thread) fix the loss of notification.
(#12988)
fd0f755b88 is described below
commit fd0f755b88930e010a572ce3bce968afc4747af2
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 2a912a4e3e..9fff2b5b9b 100644
--- a/be/src/vec/exec/volap_scan_node.cpp
+++ b/be/src/vec/exec/volap_scan_node.cpp
@@ -138,7 +138,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]
