From 0017cc0890a415ae4be85b74fe66949d8d090659 Mon Sep 17 00:00:00 2001 From: archkuang Date: Tue, 9 Jul 2024 15:08:30 +0800 Subject: [PATCH] fix style --- .../main/java/org/apache/tez/dag/app/RssDAGAppMaster.java | 5 +++-- .../java/org/apache/uniffle/test/ShuffleServerGrpcTest.java | 3 ++- .../uniffle/client/impl/grpc/CoordinatorGrpcClient.java | 6 ++++-- 3 files changed, 9 insertions(+), 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 index 68355f1aeb..cb0ebba7cc 100644 --- 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 index 3542078c47..af886e6e85 100644 --- 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 index 7e59014c37..cb5163d710 100644 --- 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)