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 6f967b4db5 [core] Make metadata.stats-dense-store default value is
true (#4617)
add 39b82ec160 [flink] Replace legacy SinkFunction with v2 Sink (#4612)
No new revisions were added by this update.
Summary of changes:
.../sink2/WriterInitContext.java} | 4 +-
.../api/functions/sink/v2/DiscardingSink.java | 58 +++++++++++++++
.../api/connector/sink2/WriterInitContext.java} | 4 +-
.../api/functions/sink/v2/DiscardingSink.java | 58 +++++++++++++++
.../sink2/WriterInitContext.java} | 7 +-
.../api/functions/sink/v2/DiscardingSink.java | 59 +++++++++++++++
.../api/connector/sink2/WriterInitContext.java} | 4 +-
.../api/functions/sink/v2/DiscardingSink.java | 59 +++++++++++++++
.../flink/sink/cdc/FlinkCdcMultiTableSink.java | 4 +-
.../flink/sink/cdc/FlinkCdcMultiTableSinkTest.java | 5 +-
.../apache/paimon/flink/action/CloneAction.java | 4 +-
.../paimon/flink/service/QueryAddressRegister.java | 84 ++++++++++++----------
.../apache/paimon/flink/service/QueryService.java | 2 +-
.../flink/sink/CombinedTableCompactorSink.java | 4 +-
.../org/apache/paimon/flink/sink/FlinkSink.java | 4 +-
.../flink/sink/WriterChainingStrategyTest.java | 2 +-
16 files changed, 304 insertions(+), 58 deletions(-)
copy
paimon-flink/paimon-flink-1.15/src/main/java/org/apache/flink/api/{common/serialization/SerializerConfig.java
=> connector/sink2/WriterInitContext.java} (85%)
create mode 100644
paimon-flink/paimon-flink-1.15/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java
copy
paimon-flink/{paimon-flink-1.15/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java
=>
paimon-flink-1.16/src/main/java/org/apache/flink/api/connector/sink2/WriterInitContext.java}
(85%)
create mode 100644
paimon-flink/paimon-flink-1.16/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java
copy
paimon-flink/paimon-flink-1.17/src/main/java/org/apache/flink/api/{common/serialization/SerializerConfigImpl.java
=> connector/sink2/WriterInitContext.java} (81%)
create mode 100644
paimon-flink/paimon-flink-1.17/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java
copy
paimon-flink/{paimon-flink-1.15/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java
=>
paimon-flink-1.18/src/main/java/org/apache/flink/api/connector/sink2/WriterInitContext.java}
(85%)
create mode 100644
paimon-flink/paimon-flink-1.18/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java
