Address comments

Jackie-Jiang · Jackie-Jiang · commit b239724b9681 · 2022-05-26T13:12:46.000-07:00
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java
@@ -1483,6 +1483,7 @@ static void setOptions(PinotQuery pinotQuery, long requestId, String query, Json
     if (jsonRequest.has(Broker.Request.DEBUG_OPTIONS)) {
       Map<String, String> debugOptions = getOptionsFromJson(jsonRequest, Broker.Request.DEBUG_OPTIONS);
       if (!debugOptions.isEmpty()) {
+        // TODO: Do not set debug options after releasing 0.11.0. Currently we kept it for backward compatibility.
         LOGGER.debug("Debug options are set to: {} for request {}: {}", debugOptions, requestId, query);
         pinotQuery.setDebugOptions(debugOptions);
 
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentselector/RealtimeSegmentSelector.java b/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentselector/RealtimeSegmentSelector.java
@@ -93,8 +93,8 @@ public void onAssignmentChange(IdealState idealState, ExternalView externalView,
         if (instanceStateMap.containsValue(SegmentStateModel.CONSUMING)) {
           // Keep the first CONSUMING segment for each partition
           LLCSegmentName llcSegmentName = new LLCSegmentName(segment);
-          partitionIdToFirstConsumingLLCSegmentMap.compute(llcSegmentName.getPartitionGroupId(),
-              (k, consumingSegment) -> {
+          partitionIdToFirstConsumingLLCSegmentMap
+              .compute(llcSegmentName.getPartitionGroupId(), (k, consumingSegment) -> {
                 if (consumingSegment == null) {
                   return llcSegmentName;
                 } else {
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/startree/operator/StarTreeFilterOperator.java b/pinot-core/src/main/java/org/apache/pinot/core/startree/operator/StarTreeFilterOperator.java
@@ -197,14 +197,14 @@ private BaseFilterOperator getFilterOperator() {
         int numPredicateEvaluators = predicateEvaluators.size();
         if (numPredicateEvaluators == 1) {
           // Single predicate evaluator
-          childFilterOperators.add(
-              FilterOperatorUtils.getLeafFilterOperator(predicateEvaluators.get(0), dataSource, numDocs));
+          childFilterOperators
+              .add(FilterOperatorUtils.getLeafFilterOperator(predicateEvaluators.get(0), dataSource, numDocs));
         } else {
           // Predicate evaluators conjoined with OR
           List<BaseFilterOperator> orChildFilterOperators = new ArrayList<>(numPredicateEvaluators);
           for (PredicateEvaluator childPredicateEvaluator : predicateEvaluators) {
-            orChildFilterOperators.add(
-                FilterOperatorUtils.getLeafFilterOperator(childPredicateEvaluator, dataSource, numDocs));
+            orChildFilterOperators
+                .add(FilterOperatorUtils.getLeafFilterOperator(childPredicateEvaluator, dataSource, numDocs));
           }
           childFilterOperators.add(
               FilterOperatorUtils.getOrFilterOperator(_queryContext, orChildFilterOperators, numDocs));
