From cffcc58f8fb5dcc2fbe186dede70c44b9e58703a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E6=99=9F=20Wu=20Sheng?= Date: Sat, 16 May 2020 22:54:28 +0800 Subject: [PATCH] The NoneStreamEsDAO implementation doesn't use real index name to insert. (#4796) --- .../storage/plugin/elasticsearch/base/NoneStreamEsDAO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/NoneStreamEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/NoneStreamEsDAO.java index 28593239a..1895ed8d9 100644 --- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/NoneStreamEsDAO.java +++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/NoneStreamEsDAO.java @@ -41,7 +41,7 @@ public class NoneStreamEsDAO extends EsDAO implements INoneStreamDAO { @Override public void insert(Model model, NoneStream noneStream) throws IOException { XContentBuilder builder = map2builder(storageBuilder.data2Map(noneStream)); - String modelName = model.getName(); + String modelName = TimeSeriesUtils.writeIndexName(model, noneStream.getTimeBucket()); getClient().forceInsert(modelName, noneStream.id(), builder); } }