Fixed the bug which the db search aggregate not set size.

That will make the represent data not incomplete.

apm-collector/apm-collector-worker/src/main/java/org/skywalking/apm/collector/worker/node/persistence/NodeCompLoad.java

@@ -35,7 +35,7 @@ public class NodeCompLoad extends AbstractLocalSyncWorker {
         SearchRequestBuilder searchRequestBuilder = EsClient.INSTANCE.getClient().prepareSearch(NodeCompIndex.INDEX);
         searchRequestBuilder.setTypes(NodeCompIndex.TYPE_RECORD);
         searchRequestBuilder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
-        searchRequestBuilder.setSize(100);
+        searchRequestBuilder.setSize(500);
         SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
 
         SearchHit[] searchHits = searchResponse.getHits().getHits();

apm-collector/apm-collector-worker/src/main/java/org/skywalking/apm/collector/worker/node/persistence/NodeMappingSearchWithTimeSlice.java

@@ -45,7 +45,7 @@ public class NodeMappingSearchWithTimeSlice extends AbstractLocalSyncWorker {
             searchRequestBuilder.setQuery(QueryBuilders.rangeQuery(NodeMappingIndex.TIME_SLICE).gte(search.getStartTime()).lte(search.getEndTime()));
             searchRequestBuilder.setSize(0);
 
-            searchRequestBuilder.addAggregation(AggregationBuilders.terms(NodeMappingIndex.AGG_COLUMN).field(NodeMappingIndex.AGG_COLUMN).size(100));
+            searchRequestBuilder.addAggregation(AggregationBuilders.terms(NodeMappingIndex.AGG_COLUMN).field(NodeMappingIndex.AGG_COLUMN).size(500));
             SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
 
             Terms genders = searchResponse.getAggregations().get(NodeMappingIndex.AGG_COLUMN);

apm-collector/apm-collector-worker/src/main/java/org/skywalking/apm/collector/worker/noderef/persistence/NodeRefResSumGroupWithTimeSlice.java

@@ -46,7 +46,7 @@ public class NodeRefResSumGroupWithTimeSlice extends AbstractLocalSyncWorker {
             searchRequestBuilder.setQuery(QueryBuilders.rangeQuery(NodeRefResSumIndex.TIME_SLICE).gte(search.getStartTime()).lte(search.getEndTime()));
             searchRequestBuilder.setSize(0);
 
-            TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms(NodeRefResSumIndex.TIME_SLICE).field(NodeRefResSumIndex.TIME_SLICE);
+            TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms(NodeRefResSumIndex.TIME_SLICE).field(NodeRefResSumIndex.TIME_SLICE).size(500);
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.ONE_SECOND_LESS).field(NodeRefResSumIndex.ONE_SECOND_LESS));
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.THREE_SECOND_LESS).field(NodeRefResSumIndex.THREE_SECOND_LESS));
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.FIVE_SECOND_LESS).field(NodeRefResSumIndex.FIVE_SECOND_LESS));

apm-collector/apm-collector-worker/src/main/java/org/skywalking/apm/collector/worker/noderef/persistence/NodeRefResSumSearchWithTimeSlice.java

@@ -47,7 +47,7 @@ public class NodeRefResSumSearchWithTimeSlice extends AbstractLocalSyncWorker {
             searchRequestBuilder.setQuery(QueryBuilders.rangeQuery(NodeRefResSumIndex.TIME_SLICE).gte(search.getStartTime()).lte(search.getEndTime()));
             searchRequestBuilder.setSize(0);
 
-            TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms(NodeRefResSumIndex.AGG_COLUMN).field(NodeRefResSumIndex.AGG_COLUMN);
+            TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms(NodeRefResSumIndex.AGG_COLUMN).field(NodeRefResSumIndex.AGG_COLUMN).size(500);
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.ONE_SECOND_LESS).field(NodeRefResSumIndex.ONE_SECOND_LESS));
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.THREE_SECOND_LESS).field(NodeRefResSumIndex.THREE_SECOND_LESS));
             aggregationBuilder.subAggregation(AggregationBuilders.sum(NodeRefResSumIndex.FIVE_SECOND_LESS).field(NodeRefResSumIndex.FIVE_SECOND_LESS));

apm-collector/apm-collector-worker/src/main/java/org/skywalking/apm/collector/worker/noderef/persistence/NodeRefSearchWithTimeSlice.java

@@ -45,7 +45,7 @@ public class NodeRefSearchWithTimeSlice extends AbstractLocalSyncWorker {
             searchRequestBuilder.setQuery(QueryBuilders.rangeQuery(NodeRefIndex.TIME_SLICE).gte(search.getStartTime()).lte(search.getEndTime()));
             searchRequestBuilder.setSize(0);
 
-            searchRequestBuilder.addAggregation(AggregationBuilders.terms(NodeRefIndex.AGG_COLUMN).field(NodeRefIndex.AGG_COLUMN).size(100));
+            searchRequestBuilder.addAggregation(AggregationBuilders.terms(NodeRefIndex.AGG_COLUMN).field(NodeRefIndex.AGG_COLUMN).size(200));
 
             SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
 

apm-collector/apm-collector-worker/src/main/resources/collector.config

@@ -20,7 +20,7 @@ cluster.seed_nodes=127.0.0.1:11800
   es.cluster.transport.sniffer = true
 
 # The elasticsearch nodes of cluster, separated by comma, e.g. nodes=ip:port, ip:port
-es.cluster.nodes=127.0.0.1:9300
+es.cluster.nodes=10.0.0.10:9300
 
 #Initialized mode of elasticsearch index, default is auto.
 #Options: auto, forced, manual