From afd70e68556199347f40810126ba9a7dacab3064 Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Thu, 1 Aug 2024 23:22:14 -0700 Subject: [PATCH] For review --- .../scala/org/apache/comet/CometSparkSessionExtensions.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala b/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala index 948230527..96ec23fae 100644 --- a/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala +++ b/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala @@ -795,13 +795,13 @@ class CometSparkSessionExtensions val columnarShuffleEnabled = isCometJVMShuffleMode(conf) val msg2 = createMessage( isShuffleEnabled && !columnarShuffleEnabled && !QueryPlanSerde - .supportPartitioning(s.child.output, s.outputPartitioning) + .supportPartitioning(s.child.output, outputPartitioning) ._1, "Native shuffle: " + s"${QueryPlanSerde.supportPartitioning(s.child.output, outputPartitioning)._2}") val msg3 = createMessage( isShuffleEnabled && columnarShuffleEnabled && !QueryPlanSerde - .supportPartitioningTypes(s.child.output, s.outputPartitioning) + .supportPartitioningTypes(s.child.output, outputPartitioning) ._1, "JVM shuffle: " + s"${QueryPlanSerde.supportPartitioningTypes(s.child.output, outputPartitioning)._2}")