Skip to content

Commit 7b0f563

Browse files
committed
fix style
1 parent bfe9b76 commit 7b0f563

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -647,7 +647,10 @@ public RssSendShuffleDataResponse sendShuffleData(RssSendShuffleDataRequest requ
647647
null,
648648
request.getRetryIntervalMax(),
649649
maxRetryAttempts,
650-
t -> !request.needCancel() && !(t instanceof OutOfMemoryError) && !(t instanceof NotRetryException));
650+
t ->
651+
!request.needCancel()
652+
&& !(t instanceof OutOfMemoryError)
653+
&& !(t instanceof NotRetryException));
651654
} catch (Throwable throwable) {
652655
LOG.warn("Failed to send shuffle data due to ", throwable);
653656
isSuccessful = false;

internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,10 @@ public RssSendShuffleDataResponse sendShuffleData(RssSendShuffleDataRequest requ
235235
null,
236236
request.getRetryIntervalMax(),
237237
maxRetryAttempts,
238-
t -> !request.needCancel() && !(t instanceof OutOfMemoryError) && !(t instanceof NotRetryException));
238+
t ->
239+
!request.needCancel()
240+
&& !(t instanceof OutOfMemoryError)
241+
&& !(t instanceof NotRetryException));
239242
} catch (Throwable throwable) {
240243
LOG.warn("Failed to send shuffle data due to ", throwable);
241244
isSuccessful = false;

0 commit comments

Comments
 (0)