This is an automated email from the ASF dual-hosted git repository.
liming pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 2b2beb280 [doc] Add query performance to primary key table
add 5f00ad64a [flink] support setting uid suffix for source/sink to
improve state compatibility when jobGraph changes. (#4425)
No new revisions were added by this update.
Summary of changes:
.../generated/flink_connector_configuration.html | 12 +
.../apache/paimon/flink/FlinkConnectorOptions.java | 23 ++
.../paimon/flink/sink/DynamicBucketSink.java | 19 +-
.../org/apache/paimon/flink/sink/FlinkSink.java | 16 +
.../paimon/flink/source/FlinkSourceBuilder.java | 12 +
.../paimon/flink/FlinkJobRecoveryITCase.java | 334 +++++++++++++++++++++
6 files changed, 414 insertions(+), 2 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkJobRecoveryITCase.java
