This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 1aef675c42 [Improve][Zeta] Add RequestSlotOperation observability
metrics (#11409)
add 5b7599ded6 [Feature][Core] Add connect dry-run validation1 (#11186)
No new revisions were added by this update.
Summary of changes:
docs/en/engines/zeta/user-command.md | 24 +-
docs/zh/engines/zeta/user-command.md | 26 +-
.../table/factory/SupportSinkDryRunValidation.java | 47 ++
.../factory/SupportSourceDryRunValidation.java | 62 +++
.../DryRunConnectFailureMessageSanitizer.java | 70 +++
.../DryRunConnectFailureMessageSanitizerTest.java | 111 ++++
.../seatunnel/fake/source/FakeSourceFactory.java | 23 +-
.../jdbc/catalog/AbstractJdbcCatalog.java | 2 +-
.../jdbc/catalog/duckdb/DuckDBCatalog.java | 2 +-
.../connection/SimpleJdbcConnectionProvider.java | 2 +-
.../dialect/dsql/DsqlJdbcConnectionProvider.java | 2 +-
.../dialect/hive/HiveJdbcConnectionProvider.java | 2 +-
.../seatunnel/jdbc/sink/JdbcSinkFactory.java | 186 +++++--
.../seatunnel/jdbc/source/JdbcSourceFactory.java | 31 +-
.../duckdb/DuckDBConnectDryRunValidationTest.java | 222 ++++++++
.../core/starter/utils/ConfigBuilder.java | 4 +
.../core/starter/utils/ConfigBuilderTest.java | 22 +
.../starter/seatunnel/args/ClientCommandArgs.java | 11 +-
.../seatunnel/command/DryRunConnectValidator.java | 572 +++++++++++++++++++++
.../command/SeaTunnelConfValidateCommand.java | 37 +-
.../seatunnel/args/ClientCommandArgsTest.java | 17 +-
.../seatunnel/command/DryRunTestSinkFactory.java | 39 +-
.../seatunnel/command/DryRunTestSourceFactory.java | 92 ++++
.../command/SeaTunnelConfValidateCommandTest.java | 352 +++++++++++++
.../org.apache.seatunnel.api.table.factory.Factory | 7 +-
25 files changed, 1877 insertions(+), 88 deletions(-)
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/SupportSinkDryRunValidation.java
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/SupportSourceDryRunValidation.java
create mode 100644
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DryRunConnectFailureMessageSanitizer.java
create mode 100644
seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/DryRunConnectFailureMessageSanitizerTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/duckdb/DuckDBConnectDryRunValidationTest.java
create mode 100644
seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/DryRunConnectValidator.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSinkFactory.java
=>
seatunnel-core/seatunnel-starter/src/test/java/org/apache/seatunnel/core/starter/seatunnel/command/DryRunTestSinkFactory.java
(50%)
create mode 100644
seatunnel-core/seatunnel-starter/src/test/java/org/apache/seatunnel/core/starter/seatunnel/command/DryRunTestSourceFactory.java
copy
seatunnel-config/seatunnel-config-shade/src/test/resources/seatunnel/configWithSpecialKey.conf
=>
seatunnel-core/seatunnel-starter/src/test/resources/META-INF/services/org.apache.seatunnel.api.table.factory.Factory
(83%)
