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 87121e260b [core] delete external paths when drop table (#5122)
add 8044eb398d [cdc] Eager init to force creating snapshot even no data
(#5170)
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/kafka_sync_database.html | 5 +
.../flink/action/cdc/SyncDatabaseActionBase.java | 23 ++++
.../flink/sink/cdc/FlinkCdcMultiTableSink.java | 24 +++-
.../sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java | 20 ++-
.../flink/sink/cdc/FlinkCdcMultiTableSinkTest.java | 4 +-
.../paimon/flink/sink/StoreMultiCommitter.java | 34 +++++
.../org/apache/paimon/flink/sink/TableFilter.java | 142 +++++++++++++++++++++
.../paimon/flink/sink/StoreMultiCommitterTest.java | 3 +-
.../apache/paimon/flink/sink/TableFilterTest.java | 105 +++++++++++++++
9 files changed, 353 insertions(+), 7 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/TableFilter.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/TableFilterTest.java
