This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new cffcc58  The NoneStreamEsDAO implementation doesn't use real index 
name to insert. (#4796)
cffcc58 is described below

commit cffcc58f8fb5dcc2fbe186dede70c44b9e58703a
Author: 吴晟 Wu Sheng <[email protected]>
AuthorDate: Sat May 16 22:54:28 2020 +0800

    The NoneStreamEsDAO implementation doesn't use real index name to insert. 
(#4796)
---
 .../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);
     }
 }

Reply via email to