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 98c161e0c7 [doc] fix doc error (#5087)
add 03d673ee66 [flink] Support parallelismConfigurable (#5076)
No new revisions were added by this update.
Summary of changes:
...eamOperatorUtils.java => ParallelismUtils.java} | 26 ++++++----
.../paimon/flink/utils/ParallelismUtils.java} | 26 ++++++----
.../paimon/flink/sink/cdc/CdcSinkBuilder.java | 5 +-
.../flink/sink/cdc/FlinkCdcMultiTableSink.java | 28 +++++------
.../sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java | 9 ++--
.../apache/paimon/flink/shuffle/RangeShuffle.java | 15 ++++--
.../flink/sink/CombinedTableCompactorSink.java | 56 +++++++++++-----------
.../flink/sink/DynamicBucketCompactSink.java | 8 ++--
.../paimon/flink/sink/DynamicBucketSink.java | 8 ++--
.../org/apache/paimon/flink/sink/FlinkSink.java | 35 ++++++++------
.../apache/paimon/flink/sink/FlinkSinkBuilder.java | 31 +++++++-----
.../paimon/flink/sink/FlinkStreamPartitioner.java | 4 +-
.../paimon/flink/sink/UnawareBucketSink.java | 18 ++++---
.../flink/sink/index/GlobalDynamicBucketSink.java | 5 +-
.../paimon/flink/source/FlinkSourceBuilder.java | 10 ++--
.../paimon/flink/utils/ParallelismUtils.java | 52 ++++++++++++++++++++
16 files changed, 213 insertions(+), 123 deletions(-)
copy
paimon-flink/paimon-flink-1.15/src/main/java/org/apache/paimon/flink/utils/{SingleOutputStreamOperatorUtils.java
=> ParallelismUtils.java} (55%)
copy
paimon-flink/{paimon-flink-1.15/src/main/java/org/apache/paimon/flink/utils/SingleOutputStreamOperatorUtils.java
=>
paimon-flink-1.16/src/main/java/org/apache/paimon/flink/utils/ParallelismUtils.java}
(55%)
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/ParallelismUtils.java
