diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/WorkerConfig.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/WorkerConfig.java index 9a4be2eee55ac121c113671a9f7c6b7f0b4b5cb1..fcb5e902b3c57cbb507bb1b6aadb894c43eb5575 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/WorkerConfig.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/WorkerConfig.java @@ -48,27 +48,27 @@ public class WorkerConfig extends ClusterConfig { public static class WorkerNum { public static class Node { public static class NodeDayAgg { - public static int Size = 1024; + public static int Value = 10; } public static class NodeHourAgg { - public static int Size = 1024; + public static int Value = 10; } public static class NodeMinuteAgg { - public static int Size = 1024; + public static int Value = 10; } public static class NodeMappingDayAgg { - public static int Size = 1024; + public static int Value = 10; } public static class NodeMappingHourAgg { - public static int Size = 1024; + public static int Value = 10; } public static class NodeMappingMinuteAgg { - public static int Size = 1024; + public static int Value = 10; } } } @@ -173,6 +173,5 @@ public class WorkerConfig extends ClusterConfig { public static class DAGNodeRefAnalysis { public static int Size = 1024; } - } } diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompAgg.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompAgg.java index 62131e0aecd4f69c67308f8ba52a0e306548eecd..fd2fd46a051e3ac41d32355ed86da03e5984fcd5 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompAgg.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompAgg.java @@ -44,7 +44,7 @@ public class NodeCompAgg extends AbstractClusterWorker { @Override public int workerNum() { - return WorkerConfig.WorkerNum.Node.NodeDayAgg.Size; + return WorkerConfig.WorkerNum.Node.NodeDayAgg.Value; } } diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAgg.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAgg.java index 4904ead3c6b951f715bd758c3b0e1bba92f040bc..12e36e053c32cc8b9da52ba42b95c401a9d0dc1b 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAgg.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAgg.java @@ -44,7 +44,7 @@ public class NodeMappingDayAgg extends AbstractClusterWorker { @Override public int workerNum() { - return WorkerConfig.WorkerNum.Node.NodeMappingDayAgg.Size; + return WorkerConfig.WorkerNum.Node.NodeMappingDayAgg.Value; } } diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAgg.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAgg.java index e92d91cecbd30d348b123fa67b153bc7f70dec0a..2e614266b183a7c3e491744a4e77a74b87772350 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAgg.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAgg.java @@ -44,7 +44,7 @@ public class NodeMappingHourAgg extends AbstractClusterWorker { @Override public int workerNum() { - return WorkerConfig.WorkerNum.Node.NodeMappingHourAgg.Size; + return WorkerConfig.WorkerNum.Node.NodeMappingHourAgg.Value; } } diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAgg.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAgg.java index bad32d26a4b473bd208c5af6b2eb856dfed24c93..d21ec90980f846b07343e3d65c482d9ef1509b41 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAgg.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAgg.java @@ -44,7 +44,7 @@ public class NodeMappingMinuteAgg extends AbstractClusterWorker { @Override public int workerNum() { - return WorkerConfig.WorkerNum.Node.NodeMappingMinuteAgg.Size; + return WorkerConfig.WorkerNum.Node.NodeMappingMinuteAgg.Value; } } diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAggTestCase.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAggTestCase.java index d0a30900040739b0a1d34ed4154354960315a8d7..092f437659311039b64cc03f5d4d285ae86c6193 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAggTestCase.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAggTestCase.java @@ -61,7 +61,7 @@ public class NodeMappingDayAggTestCase { Assert.assertEquals(NodeMappingDayAgg.class.getSimpleName(), NodeMappingDayAgg.Factory.INSTANCE.workerInstance(null).getClass().getSimpleName()); int testSize = 10; - WorkerConfig.WorkerNum.Node.NodeMappingDayAgg.Size = testSize; + WorkerConfig.WorkerNum.Node.NodeMappingDayAgg.Value = testSize; Assert.assertEquals(testSize, NodeMappingDayAgg.Factory.INSTANCE.workerNum()); } diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAggTestCase.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAggTestCase.java index 78af662cd117c499dd603e77b68a8477c5e88a4d..c12e17ca2f839b01c01fdc565db4b47bdbcbc859 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAggTestCase.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAggTestCase.java @@ -61,7 +61,7 @@ public class NodeMappingHourAggTestCase { Assert.assertEquals(NodeMappingHourAgg.class.getSimpleName(), NodeMappingHourAgg.Factory.INSTANCE.workerInstance(null).getClass().getSimpleName()); int testSize = 10; - WorkerConfig.WorkerNum.Node.NodeMappingHourAgg.Size = testSize; + WorkerConfig.WorkerNum.Node.NodeMappingHourAgg.Value = testSize; Assert.assertEquals(testSize, NodeMappingHourAgg.Factory.INSTANCE.workerNum()); } diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAggTestCase.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAggTestCase.java index d65b663fad8c019a3639d37a01871c5eebe115a7..f48a5f67a30d92c125ea0f9b59f0e303da381ee0 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAggTestCase.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAggTestCase.java @@ -61,7 +61,7 @@ public class NodeMappingMinuteAggTestCase { Assert.assertEquals(NodeMappingMinuteAgg.class.getSimpleName(), NodeMappingMinuteAgg.Factory.INSTANCE.workerInstance(null).getClass().getSimpleName()); int testSize = 10; - WorkerConfig.WorkerNum.Node.NodeMappingMinuteAgg.Size = testSize; + WorkerConfig.WorkerNum.Node.NodeMappingMinuteAgg.Value = testSize; Assert.assertEquals(testSize, NodeMappingMinuteAgg.Factory.INSTANCE.workerNum()); }