From 408bbf86e6bc75f6a95f11c346daecd570f6b45e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E6=99=9F=20Wu=20Sheng?= Date: Thu, 15 Jul 2021 19:31:50 +0800 Subject: [PATCH] Fix a misused variable. (#7309) --- .../storage/plugin/elasticsearch/base/MetricsEsDAO.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 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++) {