This is an automated email from the ASF dual-hosted git repository.

zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new afe1b9a52 improvement(spark): Move the reassign info logs to DEBUG to 
cut down on noise (#2677)
afe1b9a52 is described below

commit afe1b9a52d69abc28c8e693620c5170e101dbf88
Author: Junfan Zhang <[email protected]>
AuthorDate: Wed Nov 19 12:04:27 2025 +0800

    improvement(spark): Move the reassign info logs to DEBUG to cut down on 
noise (#2677)
    
    ### What changes were proposed in this pull request?
    
    Move the reassign info logs to DEBUG to cut down on noise
    
    ### Why are the changes needed?
    
    to reduce nosiy logs
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    Needn't
---
 .../java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java  | 2 +-
 .../org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java
 
b/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java
index 5f9c48bb4..b426d6145 100644
--- 
a/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java
+++ 
b/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java
@@ -1170,7 +1170,7 @@ public abstract class RssShuffleManagerBase implements 
RssShuffleManagerInterfac
             getAppId(), shuffleId, newServerToPartitions, 
getRemoteStorageInfo());
       }
 
-      LOG.info(
+      LOG.debug(
           "Finished reassignOnBlockSendFailure request and cost {}(ms). is 
partition split:{}. Reassign result: {}",
           System.currentTimeMillis() - startTime,
           partitionSplit,
diff --git 
a/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java
 
b/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java
index 1f3d4c8b2..5d464b637 100644
--- 
a/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java
+++ 
b/client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java
@@ -318,7 +318,7 @@ public class ShuffleManagerGrpcService extends 
ShuffleManagerImplBase {
     RssProtos.StatusCode code = RssProtos.StatusCode.INTERNAL_ERROR;
     RssProtos.ReassignOnBlockSendFailureResponse reply;
     try {
-      LOG.info(
+      LOG.debug(
           "Accepted reassign request on block sent failure for shuffleId: {}, 
stageId: {}, stageAttemptNumber: {} from taskAttemptId: {} on executorId: {} 
while partition split:{}",
           request.getShuffleId(),
           request.getStageId(),

Reply via email to