fix

alibaba · Dec 25, 2024 · fbf864e · fbf864e
1 parent d22604d
commit fbf864e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/runner/ProcessorRunner.cpp b/core/runner/ProcessorRunner.cpp
@@ -145,13 +145,13 @@ void ProcessorRunner::Run(uint32_t threadNo) {
         if (hasOldPipeline) {
             pipeline->SubInProcessCnt(); // old pipeline
             pipeline = PipelineManager::GetInstance()->FindConfigByName(configName); // update to new pipeline
-            pipeline->AddInProcessCnt();
             if (!pipeline) {
                 LOG_INFO(sLogger,
                          ("pipeline not found during processing, perhaps due to config deletion",
                           "discard data")("config", configName));
                 continue;
             }
+            pipeline->AddInProcessCnt();
         }
 
         if (pipeline->IsFlushingThroughGoPipeline()) {