fix

Author: forsaken628

src/query/pipeline/src/core/processor.rs

@@ -124,12 +124,17 @@ unsafe impl Send for ProcessorPtr {}
 
 unsafe impl Sync for ProcessorPtr {}
 
+thread_local! {
+    // Processor spans are created on the hot path, so cache the current thread name per thread.
+    static CURRENT_THREAD_NAME: String = std::thread::current()
+        .name()
+        .unwrap_or("unnamed")
+        .to_string();
+}
+
 impl ProcessorPtr {
     fn current_thread_name() -> String {
-        std::thread::current()
-            .name()
-            .unwrap_or("unnamed")
-            .to_string()
+        CURRENT_THREAD_NAME.with(|thread_name| thread_name.clone())
     }
 
     #[allow(clippy::arc_with_non_send_sync)]
@@ -181,10 +186,9 @@ impl ProcessorPtr {
     /// # Safety
     pub unsafe fn process(&self) -> Result<()> {
         unsafe {
-            let thread_name = Self::current_thread_name();
             let span = LocalSpan::enter_with_local_parent(format!("{}::process", self.name()))
                 .with_property(|| ("graph-node-id", self.id().index().to_string()))
-                .with_property(|| ("thread_name", thread_name.clone()));
+                .with_property(|| ("thread_name", Self::current_thread_name()));
 
             match (*self.inner.get()).process() {
                 Ok(_) => Ok(()),
@@ -210,7 +214,6 @@ impl ProcessorPtr {
             let id = self.id();
             let mut name = self.name();
             name.push_str("::async_process");
-            let thread_name = Self::current_thread_name();
 
             let task = (*self.inner.get()).async_process();
 
@@ -225,9 +228,12 @@ impl ProcessorPtr {
 
             let inner = self.inner.clone();
             async move {
-                let span = Span::enter_with_local_parent(name)
-                    .with_property(|| ("graph-node-id", id.index().to_string()))
-                    .with_property(|| ("thread_name", thread_name.clone()));
+                let span = match SpanContext::current_local_parent() {
+                    Some(parent) if parent.sampled => Span::enter_with_local_parent(name)
+                        .with_property(|| ("graph-node-id", id.index().to_string()))
+                        .with_property(|| ("thread_name", Self::current_thread_name())),
+                    _ => Span::noop(),
+                };
 
                 match task.await {
                     Ok(_) => {