This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 595cdd1ce9 [Improve][Zeta][storage] update hdfs configuration, support
more parameters (#6547)
add 20b62f3bf3 [Improve][Connector-V2] Support hadoop ha and kerberos for
paimon sink (#6585)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Paimon.md | 46 ++++++-
docs/zh/connector-v2/sink/Paimon.md | 46 ++++++-
seatunnel-connectors-v2/connector-paimon/pom.xml | 9 +-
.../paimon/catalog/PaimonCatalogFactory.java | 4 +-
.../paimon/catalog/PaimonCatalogLoader.java | 62 +++++++--
.../seatunnel/paimon/config/PaimonConfig.java | 58 ++++++++
.../paimon/config/PaimonHadoopConfiguration.java | 16 +--
.../seatunnel/paimon/config/PaimonSinkConfig.java | 36 +----
.../paimon/exception/PaimonConnectorErrorCode.java | 4 +-
.../paimon/security/PaimonSecurityContext.java | 151 +++++++++++++++++++++
.../seatunnel/paimon/sink/PaimonSink.java | 14 +-
.../seatunnel/paimon/sink/PaimonSinkFactory.java | 4 +-
.../seatunnel/paimon/sink/PaimonSinkWriter.java | 17 ++-
.../sink/commit/PaimonAggregatedCommitter.java | 28 ++--
.../seatunnel/paimon/utils/RowConverter.java | 10 +-
.../seatunnel/paimon/utils/RowConverterTest.java | 5 +-
.../e2e/connector/paimon/PaimonRecord.java | 70 ++++++++++
.../e2e/connector/paimon/PaimonSinkCDCIT.java | 95 +++++++------
.../e2e/connector/paimon/PaimonSinkHdfsIT.java | 127 +++++++++++++++++
..._case6.conf => fake_cdc_sink_paimon_case8.conf} | 54 ++++----
...conf => fake_cdc_sink_paimon_with_hdfs_ha.conf} | 17 ++-
21 files changed, 716 insertions(+), 157 deletions(-)
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/event/Event.java =>
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/config/PaimonHadoopConfiguration.java
(79%)
create mode 100644
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/security/PaimonSecurityContext.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonRecord.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonSinkHdfsIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/resources/{fake_cdc_sink_paimon_case6.conf
=> fake_cdc_sink_paimon_case8.conf} (66%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/resources/{fake_cdc_sink_paimon_case1.conf
=> fake_cdc_sink_paimon_with_hdfs_ha.conf} (74%)
