This is an automated email from the ASF dual-hosted git repository. wusheng pushed a commit to branch profile-es-bug in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit 7a7e84b368639316095f92051c8cec9172a1318d Author: Wu Sheng <[email protected]> AuthorDate: Sat May 16 21:34:33 2020 +0800 The NoneStreamEsDAO implementation doesn't use real index name to insert. --- .../oap/server/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 2859323..1895ed8 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); } }
