diff --git a/spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala b/spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala index 232b6bf17..e98c69af3 100644 --- a/spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala +++ b/spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala @@ -313,7 +313,7 @@ object CometShuffleExchangeExec extends ShimCometShuffleExchangeExec { // seed by hashing will help. Refer to SPARK-21782 for more details. val partitionId = TaskContext.get().partitionId() var position = new XORShiftRandom(partitionId).nextInt(numPartitions) - (row: InternalRow) => { + (_: InternalRow) => { // The HashPartitioner will handle the `mod` by the number of partitions position += 1 position