From 40e4d7fc58e68a075cee8a14016f971531266a5b Mon Sep 17 00:00:00 2001 From: ulysses-you Date: Tue, 6 Aug 2024 17:27:20 +0800 Subject: [PATCH] nit --- .../src/main/scala/org/apache/paimon/spark/PaimonScan.scala | 1 - 1 file changed, 1 deletion(-) 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) }