[Debug](scan) Add debug log for find p0 scan coredump in pipeline (ap…

…ache#24202)
zhangstar333 · Sep 12, 2023 · dbf509e · dbf509e
1 parent b602369
commit dbf509e
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/be/src/vec/exec/scan/pip_scanner_context.h b/be/src/vec/exec/scan/pip_scanner_context.h
@@ -176,6 +176,15 @@ class PipScannerContext : public vectorized::ScannerContext {
         }
     }
 
+    std::string debug_string() override {
+        auto res = ScannerContext::debug_string();
+        for (int i = 0; i < _blocks_queues.size(); ++i) {
+            res += " queue " + std::to_string(i) + ":size " +
+                   std::to_string(_blocks_queues[i].size_approx());
+        }
+        return res;
+    }
+
 private:
     int _next_queue_to_feed = 0;
     std::vector<moodycamel::ConcurrentQueue<vectorized::BlockUPtr>> _blocks_queues;

diff --git a/be/src/vec/exec/scan/scanner_context.h b/be/src/vec/exec/scan/scanner_context.h
@@ -131,7 +131,7 @@ class ScannerContext {
 
     bool no_schedule();
 
-    std::string debug_string();
+    virtual std::string debug_string();
 
     RuntimeState* state() { return _state; }
 

diff --git a/be/src/vec/exec/scan/vscan_node.cpp b/be/src/vec/exec/scan/vscan_node.cpp
@@ -279,6 +279,10 @@ Status VScanNode::get_next(RuntimeState* state, vectorized::Block* block, bool*
         return Status::OK();
     }
 
+    if (scan_block == nullptr) {
+        LOG(FATAL) << "Scan block nullptr error _context_queue_id:" << _context_queue_id
+                   << " context debug string:" << _scanner_ctx->debug_string();
+    }
     // get scanner's block memory
     block->swap(*scan_block);
     _scanner_ctx->return_free_block(std::move(scan_block));