[skywalking] 01/01: Fix NoneStream model has wrong downsampling

[wu...@apache.org]

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

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

commit e5a443ad170eede14235db63f71ed7570d0056f5
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Tue May 17 23:21:42 2022 +0800

    Fix NoneStream model has wrong downsampling
---
 docs/en/changes/changes.md                                             | 3 ++-
 .../oap/server/core/analysis/worker/NoneStreamProcessor.java           | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md
index 982c17ea67..10d044c152 100644
--- a/docs/en/changes/changes.md
+++ b/docs/en/changes/changes.md
@@ -57,7 +57,8 @@
 * Remove `Layer` concept form `Process`.
 * Update to list all eBPF profiling schedulers without duration.
 * Storage(ElasticSearch): add search options to tolerate inexisting indices.
-* Fix the problem that `MQ` has the wrong `Layer` type
+* Fix the problem that `MQ` has the wrong `Layer` type.
+* Fix NoneStream model has wrong downsampling(was Second, should be Minute).
 
 #### UI
 
diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/NoneStreamProcessor.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/NoneStreamProcessor.java
index 418190eef2..7b53ad2ee9 100644
--- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/NoneStreamProcessor.java
+++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/NoneStreamProcessor.java
@@ -78,7 +78,7 @@ public class NoneStreamProcessor implements StreamProcessor<NoneStream> {
 
         ModelCreator modelSetter = moduleDefineHolder.find(CoreModule.NAME).provider().getService(ModelCreator.class);
         // None stream doesn't read data from database during the persistent process. Keep the timeRelativeID == false always.
-        Model model = modelSetter.add(streamClass, stream.scopeId(), new Storage(stream.name(), false, DownSampling.Second), true);
+        Model model = modelSetter.add(streamClass, stream.scopeId(), new Storage(stream.name(), false, DownSampling.Minute), true);
 
         final NoneStreamPersistentWorker persistentWorker = new NoneStreamPersistentWorker(moduleDefineHolder, model, noneStream);
         workers.put(streamClass, persistentWorker);