File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -236,14 +236,11 @@ case class PaimonSparkWriter(table: FileStoreTable) {
236236 )
237237 }
238238
239- case BUCKET_UNAWARE =>
240- // Topology: input ->
239+ case BUCKET_UNAWARE | POSTPONE_MODE =>
241240 writeWithoutBucket(data)
242241
243242 case HASH_FIXED =>
244- if (table.bucketSpec().getNumBuckets == POSTPONE_BUCKET ) {
245- writeWithoutBucket(data)
246- } else if (paimonExtensionEnabled && BucketFunction .supportsTable(table)) {
243+ if (paimonExtensionEnabled && BucketFunction .supportsTable(table)) {
247244 // Topology: input -> shuffle by partition & bucket
248245 val bucketNumber = table.coreOptions().bucket()
249246 val bucketKeyCol = tableSchema
You can’t perform that action at this time.
0 commit comments