File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff 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 ;
Original file line number Diff line number Diff 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 ;
You can’t perform that action at this time.
0 commit comments