fix style

apache · Jul 10, 2024 · 0017cc0 · 0017cc0
1 parent e91489f
commit 0017cc0
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 5 deletions.
diff --git a/client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java b/client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java
@@ -203,8 +203,9 @@ public static void initAndStartRSSClient(final RssDAGAppMaster appMaster, Config
     appMaster.heartBeatExecutorService.scheduleAtFixedRate(
         () -> {
           try {
-            appMaster.getShuffleWriteClient().sendAppHeartbeat(strAppAttemptId, "user",
-                heartbeatTimeout);
+            appMaster
+                .getShuffleWriteClient()
+                .sendAppHeartbeat(strAppAttemptId, "user", heartbeatTimeout);
             if (LOG.isDebugEnabled()) {
               LOG.debug("Finish send heartbeat to coordinator and servers");
             }

diff --git a/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerGrpcTest.java b/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerGrpcTest.java
@@ -784,7 +784,8 @@ public void rpcMetricsTest() throws Exception {
             .getCounterMap()
             .get(ShuffleServerGrpcMetrics.APP_HEARTBEAT_METHOD)
             .get();
-    grpcShuffleServerClient.sendHeartBeat(new RssAppHeartBeatRequest(appId, StringUtils.EMPTY, 10000));
+    grpcShuffleServerClient.sendHeartBeat(
+        new RssAppHeartBeatRequest(appId, StringUtils.EMPTY, 10000));
     newValue =
         grpcShuffleServers
             .get(0)

diff --git a/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java b/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java
@@ -236,8 +236,10 @@ public RssSendHeartBeatResponse sendHeartBeat(RssSendHeartBeatRequest request) {
   @Override
   public RssAppHeartBeatResponse sendAppHeartBeat(RssAppHeartBeatRequest request) {
     RssProtos.AppHeartBeatRequest rpcRequest =
-        RssProtos.AppHeartBeatRequest.newBuilder().setAppId(request.getAppId())
-            .setUser(request.getUser()).build();
+        RssProtos.AppHeartBeatRequest.newBuilder()
+            .setAppId(request.getAppId())
+            .setUser(request.getUser())
+            .build();
     RssProtos.AppHeartBeatResponse rpcResponse =
         blockingStub
             .withDeadlineAfter(request.getTimeoutMs(), TimeUnit.MILLISECONDS)