This is an automated email from the ASF dual-hosted git repository.
csy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git
The following commit(s) were added to refs/heads/master by this push:
new 5bbfc45a [AURON-1988] Fix empty log message in
AuronUniffleShuffleReader. (#1989)
5bbfc45a is described below
commit 5bbfc45ad2571288531bf5cca45a7197b4c9fe6b
Author: slfan1989 <[email protected]>
AuthorDate: Sun Feb 8 17:19:05 2026 +0800
[AURON-1988] Fix empty log message in AuronUniffleShuffleReader. (#1989)
### Which issue does this PR close?
Closes #1988
### Rationale for this change
Fix an empty log statement in `AuronUniffleShuffleReader` that provided
no useful information when empty shuffle partitions were detected.
### What changes are included in this PR?
The original code had an empty log message (`logInfo(s"")`), which
provides no value for debugging or monitoring. This change adds
meaningful information including the count and IDs of empty shuffle
partitions.
### Are there any user-facing changes?
No, this is an internal logging improvement only.
### How was this patch tested?
No.
---------
Signed-off-by: slfan1989 <[email protected]>
---
.../execution/auron/shuffle/uniffle/AuronUniffleShuffleReader.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/thirdparty/auron-uniffle/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/uniffle/AuronUniffleShuffleReader.scala
b/thirdparty/auron-uniffle/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/uniffle/AuronUniffleShuffleReader.scala
index c4b1ca31..9a152eca 100644
---
a/thirdparty/auron-uniffle/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/uniffle/AuronUniffleShuffleReader.scala
+++
b/thirdparty/auron-uniffle/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/uniffle/AuronUniffleShuffleReader.scala
@@ -22,6 +22,7 @@ import java.util
import scala.annotation.nowarn
import scala.collection.AbstractIterator
+import scala.collection.JavaConverters._
import org.apache.commons.lang3.reflect.FieldUtils
import org.apache.hadoop.conf.Configuration
@@ -164,7 +165,8 @@ class AuronUniffleShuffleReader[K, C](
}
}
if (!emptyPartitionIds.isEmpty) {
- logInfo(s"")
+ logDebug(s"Found ${emptyPartitionIds
+ .size()} empty shuffle partitions:
${emptyPartitionIds.asScala.mkString(",")}")
}
iterators = shuffleDataIterList.iterator()
if (iterators.hasNext) {
