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 094e92510 Compaction Operator parallelism in paimon MUST be one (#3758)
add 6f4aa51b0 [flink] Improve the parallelism of Flink database compaction
commit operator (#3789)
No new revisions were added by this update.
Summary of changes:
.../apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java | 1 +
.../apache/paimon/flink/sink/CombinedTableCompactorSink.java | 12 +++++++++---
.../flink/sink}/MultiTableCommittableChannelComputer.java | 3 +--
3 files changed, 11 insertions(+), 5 deletions(-)
rename
paimon-flink/{paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc
=>
paimon-flink-common/src/main/java/org/apache/paimon/flink/sink}/MultiTableCommittableChannelComputer.java
(94%)
