diff --git a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java
index fe04e4d1..38f7764e 100644
--- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java
+++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java
@@ -336,7 +336,10 @@ public class BaseMetricESDAO extends BaseESDAO {
         if(null == response || null == response.getHits()
                 || null ==response.getHits().getUnusedMap()){return -1;}
 
-        return Integer.valueOf(response.getHits().getUnusedMap().getOrDefault(TOTAL, 0).toString());
+        // "total" : {"value": 123 , "relation": "XX "}
+        JSONObject jsonObjectTotal = (JSONObject) response.getHits().getUnusedMap().getOrDefault(TOTAL, 0);
+
+        return Integer.valueOf(jsonObjectTotal.get(VALUE).toString());
     }
 
     protected <T extends BaseMetricESPO> T filterMetrics(T t, List<String> metricNames){