upd

apache · Jul 9, 2024 · 607342e · 607342e
1 parent 84ae6c1
commit 607342e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/be/src/pipeline/exec/multi_cast_data_streamer.cpp b/be/src/pipeline/exec/multi_cast_data_streamer.cpp
@@ -71,9 +71,14 @@ void MultiCastDataStreamer::_copy_block(vectorized::Block* block, std::atomic_in
     for (int i = 0; i < block->columns(); ++i) {
         block->get_by_position(i).column = block->get_by_position(i).column->clone_resized(rows);
     }
+
+    std::unique_lock l(_mutex);
     un_finish_copy--;
     if (un_finish_copy == 0) {
+        l.unlock();
         _cv.notify_one();
+    } else {
+        l.unlock();
     }
 }