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(),