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 2c73863f47 [hotfix] Correct PARTITION_GENERATE_LEGACY_NAME name
add ace9a5972c [flink] Automatically detect changes of external-paths
strategy (#6024)
No new revisions were added by this update.
Summary of changes:
.../generated/flink_connector_configuration.html | 6 +
.../main/java/org/apache/paimon/CoreOptions.java | 12 +
.../sink/cdc/CdcAppendTableWriteOperator.java | 7 +
.../apache/paimon/flink/FlinkConnectorOptions.java | 9 +
.../paimon/flink/compact/AppendTableCompactor.java | 35 ++-
.../sink/AppendBypassCompactWorkerOperator.java | 13 +-
.../flink/sink/AppendCompactWorkerOperator.java | 18 +-
...pendOnlyMultiTableCompactionWorkerOperator.java | 19 +-
...endOnlySingleTableCompactionWorkerOperator.java | 11 +-
.../paimon/flink/sink/AppendTableCompactSink.java | 10 +-
.../apache/paimon/flink/sink/AppendTableSink.java | 2 +-
.../flink/sink/CombinedTableCompactorSink.java | 2 +-
.../flink/sink/DynamicBucketRowWriteOperator.java | 11 +
.../apache/paimon/flink/sink/FlinkWriteSink.java | 2 +-
.../flink/sink/RowDataStoreWriteOperator.java | 2 +-
.../paimon/flink/sink/StoreCompactOperator.java | 30 ++-
.../paimon/flink/sink/TableWriteOperator.java | 20 ++
.../apache/paimon/flink/sink/WriterRefresher.java | 105 ++++++++
.../apache/paimon/flink/AppendOnlyTableITCase.java | 76 ++++++
.../flink/PrimaryKeyFileStoreTableITCase.java | 70 ++++++
.../paimon/flink/action/CompactActionITCase.java | 147 +++++++++++
.../flink/compact/AppendTableCompactorTest.java | 3 +-
...OnlyMultiTableCompactionWorkerOperatorTest.java | 2 +-
...nlySingleTableCompactionWorkerOperatorTest.java | 6 +-
.../paimon/flink/sink/WriterRefresherTest.java | 272 +++++++++++++++++++++
25 files changed, 856 insertions(+), 34 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/WriterRefresher.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/WriterRefresherTest.java
