update

Zouxxyy · Nov 23, 2023 · b33ea59 · b33ea59
1 parent 3053cfe
commit b33ea59
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...n-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala b/...n-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala
@@ -115,7 +115,7 @@ case class WriteIntoPaimonTable(
               table,
               rowType,
               bucketColIdx,
-              assignerParallelism.toLong,
+              assignerParallelism,
               toRow,
               fromRow)
           repartitionByBucket(
@@ -239,7 +239,7 @@ object WriteIntoPaimonTable {
       fileStoreTable: FileStoreTable,
       rowType: RowType,
       bucketColIndex: Int,
-      numSparkPartitions: Long,
+      numSparkPartitions: Int,
       toRow: ExpressionEncoder.Serializer[Row],
       fromRow: ExpressionEncoder.Deserializer[Row]
   ) extends BucketProcessor {