This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 79cfadc459 [core] nested-update supports limit the input (#6309)
add 11d7bded11 [core] Cross partition can work with fixed bucket and
postpone bucket (#6307)
No new revisions were added by this update.
Summary of changes:
.../content/primary-key-table/data-distribution.md | 44 +++++++++++-----------
.../java/org/apache/paimon/table/BucketMode.java | 19 +++++-----
.../java/org/apache/paimon/KeyValueFileStore.java | 4 +-
.../org/apache/paimon/schema/SchemaValidation.java | 8 ----
.../paimon/table/AbstractFileStoreTable.java | 2 +-
.../org/apache/paimon/schema/TableSchemaTest.java | 7 ----
.../sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java | 2 +-
.../apache/paimon/flink/sink/FlinkSinkBuilder.java | 2 +-
.../org/apache/paimon/flink/CatalogITCaseBase.java | 12 +++++-
...eITCase.java => CrossPartitionTableITCase.java} | 35 ++++++++++++++++-
.../paimon/flink/FlinkJobRecoveryITCase.java | 2 +-
.../paimon/spark/commands/PaimonSparkWriter.scala | 4 +-
12 files changed, 83 insertions(+), 58 deletions(-)
rename
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/{GlobalDynamicBucketTableITCase.java
=> CrossPartitionTableITCase.java} (84%)
