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);
}
}