This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from afdcb3236b [Fix][Transform] Fix sql transform lose source type and
options (#6855)
add 4969c91dc4 [Improve][Connector-V2] Support hive catalog for paimon
sink (#6833)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Paimon.md | 105 ++++++++++++++++++++
docs/zh/connector-v2/sink/Paimon.md | 107 ++++++++++++++++++++-
.../seatunnel/common/exception/CommonError.java | 9 ++
.../common/exception/CommonErrorCode.java | 4 +-
seatunnel-connectors-v2/connector-paimon/pom.xml | 31 ++++++
.../seatunnel/paimon/catalog/PaimonCatalog.java | 13 ++-
.../paimon/catalog/PaimonCatalogEnum.java | 14 ++-
.../paimon/catalog/PaimonCatalogFactory.java | 19 ++--
.../paimon/catalog/PaimonCatalogLoader.java | 26 +++--
.../seatunnel/paimon/config/PaimonConfig.java | 45 +++++++--
.../seatunnel/paimon/sink/PaimonSinkFactory.java | 10 +-
.../e2e/connector/paimon/PaimonSinkHdfsIT.java | 71 ++++++++++++++
...c_sink_paimon_with_hdfs_with_hive_catalog.conf} | 8 +-
13 files changed, 415 insertions(+), 47 deletions(-)
copy
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/enums/PluginType.java
=>
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalogEnum.java
(79%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/resources/{fake_cdc_sink_paimon_with_hdfs_ha.conf
=> fake_cdc_sink_paimon_with_hdfs_with_hive_catalog.conf} (93%)
