diff --git a/paimon-spark/paimon-spark-3.5/src/main/scala/org/apache/paimon/spark/PaimonScan.scala b/paimon-spark/paimon-spark-3.5/src/main/scala/org/apache/paimon/spark/PaimonScan.scala index 18ebdd23b222c..13bb705ea9f36 100644 --- a/paimon-spark/paimon-spark-3.5/src/main/scala/org/apache/paimon/spark/PaimonScan.scala +++ b/paimon-spark/paimon-spark-3.5/src/main/scala/org/apache/paimon/spark/PaimonScan.scala @@ -54,7 +54,6 @@ case class PaimonScan( // so we only support one bucket key case. assert(bucketSpec.getNumBucket > 0) assert(bucketSpec.getBucketKeys.size() == 1) - Expressions.bucket(bucketSpec.getNumBucket, bucketSpec.getBucketKeys.get(0)) val key = Expressions.bucket(bucketSpec.getNumBucket, bucketSpec.getBucketKeys.get(0)) new KeyGroupedPartitioning(Array(key), lazyInputPartitions.size) }