Add some logs about join build (#8258) (#8260)

close #8257
pingcap · Oct 26, 2023 · c6eb592 · c6eb592
1 parent 4dbdcb8
commit c6eb592
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/dbms/src/Interpreters/Join.cpp b/dbms/src/Interpreters/Join.cpp
@@ -1747,12 +1747,15 @@ bool Join::finishOneBuild(size_t stream_index)
 
 void Join::finalizeBuild()
 {
-    std::unique_lock lock(build_probe_mutex);
-    if (hash_join_spill_context->getBuildSpiller())
-        hash_join_spill_context->getBuildSpiller()->finishSpill();
-    assert(active_build_threads == 0);
-    build_finished = true;
-    build_cv.notify_all();
+    {
+        std::unique_lock lock(build_probe_mutex);
+        if (hash_join_spill_context->getBuildSpiller())
+            hash_join_spill_context->getBuildSpiller()->finishSpill();
+        assert(active_build_threads == 0);
+        build_finished = true;
+        build_cv.notify_all();
+    }
+    LOG_INFO(log, "build finalize with {} entries from {} rows.", getTotalRowCount(), getTotalBuildInputRows());
 }
 
 void Join::workAfterBuildFinish(size_t stream_index)