fix: format

traas-stack · Oct 19, 2023 · 210895f · 210895f
1 parent 62887b7
commit 210895f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...g/agg-dispatcher/src/main/java/io/holoinsight/server/agg/v1/dispatcher/AggDispatcher.java b/...g/agg-dispatcher/src/main/java/io/holoinsight/server/agg/v1/dispatcher/AggDispatcher.java
@@ -205,7 +205,8 @@ public void dispatch(AuthInfo authInfo, WriteMetricsRequestV1 request) {
         ProducerRecord<AggTaskKey, AggProtos.AggTaskValue> record =
             new ProducerRecord<>(aggProperties.getTopic(), aggTaskKey, taskValue);
         kafkaProducer.send(record);
-        StatUtils.KAFKA_SEND.add(StringsKey.of("v1"), new long[]{1, taskValue.getInDataNodesCount()});
+        StatUtils.KAFKA_SEND.add(StringsKey.of("v1"),
+            new long[] {1, taskValue.getInDataNodesCount()});
       }
     }
   }