From e02f7efd0c926459e0707bcdd7d408db9ce5b07f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E6=99=9F=20Wu=20Sheng?= Date: Wed, 18 May 2022 07:50:56 +0800 Subject: [PATCH] Fix NoneStream model has wrong downsampling (#9088) --- 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 { 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);