diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java
index 4fb5090bbc..0f204c9b80 100644
--- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java
+++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java
@@ -83,9 +83,9 @@ public class MetricsEsDAO extends EsDAO implements IMetricsDAO {
         // the current day and the T-1 day(if at the edge between days)
         List<Metrics> result = new ArrayList<>(metrics.size());
         groupIndices.forEach((tableName, metricList) -> {
-            String[] ids = metrics.stream()
-                                  .map(item -> IndexController.INSTANCE.generateDocId(model, item.id()))
-                                  .toArray(String[]::new);
+            String[] ids = metricList.stream()
+                                     .map(item -> IndexController.INSTANCE.generateDocId(model, item.id()))
+                                     .toArray(String[]::new);
             try {
                 SearchResponse response = getClient().ids(tableName, ids);
                 for (int i = 0; i < response.getHits().getHits().length; i++) {