client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java [1032:1058]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
              if (response.getStatusCode() == StatusCode.SUCCESS) {
                LOG.info("Successfully unregistered shuffle from {}", shuffleServerInfo);
              } else {
                LOG.warn("Failed to unregister shuffle from {}", shuffleServerInfo);
              }
            } catch (Exception e) {
              // this request observed the unregisterRequestTimeSec timeout
              if (e instanceof StatusRuntimeException
                  && ((StatusRuntimeException) e).getStatus().getCode()
                      == Status.DEADLINE_EXCEEDED.getCode()) {
                LOG.warn(
                    "Timeout occurred while unregistering from {}. The request timeout is {}s: {}",
                    shuffleServerInfo,
                    unregisterRequestTimeSec,
                    ((StatusRuntimeException) e).getStatus().getDescription());
              } else {
                LOG.warn("Error while unregistering from {}", shuffleServerInfo, e);
              }
            }
            return null;
          },
          unregisterTimeMs,
          "unregister shuffle server",
          String.format(
              "Please consider increasing the thread pool size (%s) or the overall timeout (%ss) "
                  + "if you still think the request timeout (%ss) is sensible.",
              unregisterThreadPoolSize, unregisterTimeSec, unregisterRequestTimeSec));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java [1105:1131]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                if (response.getStatusCode() == StatusCode.SUCCESS) {
                  LOG.info("Successfully unregistered shuffle from {}", shuffleServerInfo);
                } else {
                  LOG.warn("Failed to unregister shuffle from {}", shuffleServerInfo);
                }
              } catch (Exception e) {
                // this request observed the unregisterRequestTimeSec timeout
                if (e instanceof StatusRuntimeException
                    && ((StatusRuntimeException) e).getStatus().getCode()
                        == Status.DEADLINE_EXCEEDED.getCode()) {
                  LOG.warn(
                      "Timeout occurred while unregistering from {}. The request timeout is {}s: {}",
                      shuffleServerInfo,
                      unregisterRequestTimeSec,
                      ((StatusRuntimeException) e).getStatus().getDescription());
                } else {
                  LOG.warn("Error while unregistering from {}", shuffleServerInfo, e);
                }
              }
              return null;
            },
            unregisterTimeMs,
            "unregister shuffle server",
            String.format(
                "Please consider increasing the thread pool size (%s) or the overall timeout (%ss) "
                    + "if you still think the request timeout (%ss) is sensible.",
                unregisterThreadPoolSize, unregisterTimeSec, unregisterRequestTimeSec));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



