Merge pull request #150 from yanghongzhuang/issue_149

Fixed Issue 149
uavorg · Jan 5, 2018 · 64932c8 · 64932c8
2 parents a14da33 + 4aca79f
commit 64932c8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ysis/src/main/java/com/creditease/uav/threadanalysis/http/ThreadAnalysisQueryHandler.java b/...ysis/src/main/java/com/creditease/uav/threadanalysis/http/ThreadAnalysisQueryHandler.java
@@ -163,9 +163,10 @@ private void queryDistinct(UAVHttpMessage data) {
 
         try {
             String ipport = data.getRequest("ipport");
-            AggregationBuilder agg = AggregationBuilders.terms("unique_time").field("time")
+            // TODO ES aggregation 默认最多查10条, 这里暂时改到1000，待refine
+            AggregationBuilder agg = AggregationBuilders.terms("unique_time").field("time").size(1000)
                     .order(Terms.Order.term(false))
-                    .subAggregation(AggregationBuilders.terms("unique_user").field("user"));
+                    .subAggregation(AggregationBuilders.terms("unique_user").field("user").size(1000));
 
             String date = data.getRequest("indexdate");
             String currentIndex;