You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/02/21 03:52:54 UTC
[incubator-skywalking] branch cluster-performance updated: Set
cycle to 500ms.
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch cluster-performance
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
The following commit(s) were added to refs/heads/cluster-performance by this push:
new 5800608 Set cycle to 500ms.
5800608 is described below
commit 5800608b931ec7f7926eb9955d4105d0eff3b1a1
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Thu Feb 21 11:52:46 2019 +0800
Set cycle to 500ms.
---
.gitignore | 3 ++-
.../oap/server/core/analysis/worker/IndicatorAggregateWorker.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/.gitignore b/.gitignore
index 4ae4e2c..c1e6e0b 100644
--- a/.gitignore
+++ b/.gitignore
@@ -12,4 +12,5 @@ packages/
/skywalking-agent/
/dist/
/docker/snapshot/*.gz
-.mvn/wrapper/*.jar
\ No newline at end of file
+.mvn/wrapper/*.jar
+OALLexer.tokens
diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorAggregateWorker.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorAggregateWorker.java
index 8b17e5c..f04e560 100644
--- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorAggregateWorker.java
+++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorAggregateWorker.java
@@ -55,7 +55,7 @@ public class IndicatorAggregateWorker extends AbstractWorker<Indicator> {
String name = "INDICATOR_L1_AGGREGATION";
this.dataCarrier = new DataCarrier<>("IndicatorAggregateWorker." + modelName, name, 4, 10000);
- BulkConsumePool.Creator creator = new BulkConsumePool.Creator(name, BulkConsumePool.Creator.recommendMaxSize() * 2, 1000);
+ BulkConsumePool.Creator creator = new BulkConsumePool.Creator(name, BulkConsumePool.Creator.recommendMaxSize() * 2, 500);
try {
ConsumerPoolFactory.INSTANCE.createIfAbsent(name, creator);
} catch (Exception e) {