fix checkstyle

apache · Jan 9, 2025 · 62b12db · 62b12db
1 parent 23d6c2f
commit 62b12db
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/...nsions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java b/...nsions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
@@ -537,18 +537,20 @@ private MSQTaskReportPayload runInternal(final QueryListener queryListener, fina
     return msqTaskReportPayload;
   }
 
-  private void emitSummaryMetrics(final MSQTaskReportPayload msqTaskReportPayload, final MSQSpec querySpec) {
+  private void emitSummaryMetrics(final MSQTaskReportPayload msqTaskReportPayload, final MSQSpec querySpec)
+  {
     long totalProcessedBytes = msqTaskReportPayload.getCounters() != null
         ? msqTaskReportPayload.getCounters().copyMap().values().stream().mapToLong(
             integerCounterSnapshotsMap -> integerCounterSnapshotsMap.values().stream()
                 .mapToLong(counterSnapshots -> {
                   Map<String, QueryCounterSnapshot> workerCounters = counterSnapshots.getMap();
                   return workerCounters.entrySet().stream().mapToLong(
-                      channel -> { if (channel.getKey().startsWith("input")) {
-                        ChannelCounters.Snapshot snapshot = (ChannelCounters.Snapshot) channel.getValue();
-                        return snapshot.getBytes() == null ? 0L : Arrays.stream(snapshot.getBytes()).sum();
-                      }
-                      return 0L;
+                      channel -> {
+                        if (channel.getKey().startsWith("input")) {
+                          ChannelCounters.Snapshot snapshot = (ChannelCounters.Snapshot) channel.getValue();
+                          return snapshot.getBytes() == null ? 0L : Arrays.stream(snapshot.getBytes()).sum();
+                        }
+                        return 0L;
                       }).sum();
                 }).sum()).sum()
         : 0;