From 7c05a0ab403e2c30d4e73073df722427cb1cb826 Mon Sep 17 00:00:00 2001 From: "Hongbin Ma (Mahone)" Date: Tue, 10 Dec 2024 14:39:26 +0800 Subject: [PATCH] refine warning message Signed-off-by: Hongbin Ma (Mahone) --- .../main/scala/com/nvidia/spark/rapids/GpuAggregateExec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuAggregateExec.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuAggregateExec.scala index f4ddff338f6..05b89cd593a 100644 --- a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuAggregateExec.scala +++ b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuAggregateExec.scala @@ -287,7 +287,7 @@ object AggregateUtils extends Logging { // However for some test cases with really small batch size, this can happen. So // we're just logging some warnings here. log.warn("The bucket is still too large after " + recursiveDepth + - " times of repartition, may hit a bug? Size for each batch in " + + " times of repartition. Size for each batch in " + "current bucket: " + bucket.map(_.sizeInBytes).mkString(", ") + " rows: " + bucket.map(_.numRows()).mkString(", ") + " targetMergeBatchSize: " + targetMergeBatchSize)