Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
zhengchenyu committed Oct 22, 2024
1 parent 7a5e367 commit 016363b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 016363b

Please sign in to comment.