From 77e5b65b53482dafd9c6a796b784090f1b1cb98f Mon Sep 17 00:00:00 2001
From: peng-yongsheng <8082209@qq.com>
Date: Mon, 20 Aug 2018 11:09:24 +0800
Subject: [PATCH] Invoke the function in indicator to calculate result and
 persistent to storage.

---
 .../core/analysis/worker/IndicatorPersistentWorker.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorPersistentWorker.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorPersistentWorker.java
index dd140c88b..1ac53e76e 100644
--- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorPersistentWorker.java
+++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorPersistentWorker.java
@@ -122,8 +122,11 @@ public class IndicatorPersistentWorker extends AbstractWorker<Indicator> {
     private void cacheData(Indicator input) {
         mergeDataCache.writing();
         if (mergeDataCache.containsKey(input)) {
-            mergeDataCache.get(input).combine(input);
+            Indicator indicator = mergeDataCache.get(input);
+            indicator.combine(input);
+            indicator.calculate();
         } else {
+            input.calculate();
             mergeDataCache.put(input);
         }