diff --git a/apm-collector/apm-collector-analysis/analysis-worker-model/src/main/java/org/apache/skywalking/apm/collector/analysis/worker/model/impl/MergePersistenceWorker.java b/apm-collector/apm-collector-analysis/analysis-worker-model/src/main/java/org/apache/skywalking/apm/collector/analysis/worker/model/impl/MergePersistenceWorker.java
index 4f4786eae..2fc7d8049 100644
--- a/apm-collector/apm-collector-analysis/analysis-worker-model/src/main/java/org/apache/skywalking/apm/collector/analysis/worker/model/impl/MergePersistenceWorker.java
+++ b/apm-collector/apm-collector-analysis/analysis-worker-model/src/main/java/org/apache/skywalking/apm/collector/analysis/worker/model/impl/MergePersistenceWorker.java
@@ -86,6 +86,7 @@ public abstract class MergePersistenceWorker<INPUT_AND_OUTPUT extends StreamData
         if (mergeDataCache.containsKey(input.getId())) {
             mergeDataCache.get(input.getId()).mergeAndFormulaCalculateData(input);
         } else {
+            input.calculateFormula();
             mergeDataCache.put(input.getId(), input);
         }