From 016363b7838ba43ce5369ccce77e3075d8912398 Mon Sep 17 00:00:00 2001 From: zhengchenyu Date: Tue, 22 Oct 2024 21:24:26 +0800 Subject: [PATCH] fix --- .../org/apache/uniffle/server/ShuffleServerGrpcMetrics.java | 3 ++- .../org/apache/uniffle/server/ShuffleServerGrpcService.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java b/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java index c5faf2223b..8636792c65 100644 --- a/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java +++ b/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java @@ -65,7 +65,8 @@ public class ShuffleServerGrpcMetrics extends GRPCMetrics { private static final String GRPC_GET_SHUFFLE_INDEX_TOTAL = "grpc_get_local_shuffle_index_total"; private static final String GRPC_GET_SHUFFLE_RESULT_FOR_MULTI_PART_TOTAL = "grpc_get_shuffle_result_for_multi_part_total"; - private static final String GRPC_GET_SORTED_SHUFFLE_DATA_TOTAL = "grpc_get_sorted_shuffle_data_total"; + private static final String GRPC_GET_SORTED_SHUFFLE_DATA_TOTAL = + "grpc_get_sorted_shuffle_data_total"; private static final String GRPC_START_SORT_MERGE_TOTAL = "grpc_start_sort_merge_total"; private static final String GRPC_SEND_SHUFFLE_DATA_TRANSPORT_LATENCY = diff --git a/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java b/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java index 2e8111acba..695b635919 100644 --- a/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java +++ b/server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java @@ -1501,7 +1501,8 @@ public void getSortedShuffleData( if (transportTime > 0) { shuffleServer .getGrpcMetrics() - .recordTransportTime(ShuffleServerGrpcMetrics.GET_SORTED_SHUFFLE_DATA_METHOD, transportTime); + .recordTransportTime( + ShuffleServerGrpcMetrics.GET_SORTED_SHUFFLE_DATA_METHOD, transportTime); } } StatusCode status = StatusCode.SUCCESS;