diff --git a/core/runner/ProcessorRunner.cpp b/core/runner/ProcessorRunner.cpp
index e7a42ae204..b8f18ad1a5 100644
--- a/core/runner/ProcessorRunner.cpp
+++ b/core/runner/ProcessorRunner.cpp
@@ -82,6 +82,7 @@ bool ProcessorRunner::PushQueue(QueueKey key, size_t inputIndex, PipelineEventGr
         }
         this_thread::sleep_for(chrono::milliseconds(10));
     }
+    group = std::move(item->mEventGroup);
     return false;
 }