This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 3d46b7961 [Feature][Connector-V2][Doris]Add Doris Source & Sink
connector (#3586)
add 226dc6a11 [Hotfix][OptionRule] Fix option rule about all connectors
(#3592)
No new revisions were added by this update.
Summary of changes:
.../api/configuration/util/ConfigValidator.java | 12 +--
.../api/configuration/util/OptionRule.java | 103 ++++++++++++++++-----
.../api/configuration/util/RequiredOption.java | 39 +++++---
.../configuration/util/ConfigValidatorTest.java | 61 +++++-------
.../api/configuration/util/ExpressionTest.java | 37 --------
.../api/configuration/util/OptionRuleTest.java | 87 +++++++++++++++++
.../flink/assertion/AssertFactoryTest.java | 16 ++--
.../clickhouse/ClickhouseFactoryTest.java | 17 ++--
.../seatunnel/console/ConsoleFactoryTest.java | 14 +--
.../seatunnel/datahub/DataHubFactoryTest.java | 15 ++-
.../connectors/seatunnel/DingTalkFactoryTest.java | 15 ++-
.../elasticsearch/ElasticsearchFactoryTest.java | 17 ++--
.../seatunnel/email/EmailFactoryTest.java | 15 ++-
.../seatunnel/fake/FakeFactoryTest.java} | 19 ++--
.../file/ftp/source/FtpFileSourceFactory.java | 6 +-
.../seatunnel/file/ftp/FtpFileFactoryTest.java | 17 ++--
.../file/hdfs/source/HdfsFileSourceFactory.java | 6 +-
.../seatunnel/file/hdfs/HdfsFileFactoryTest.java | 17 ++--
.../file/local/source/LocalFileSourceFactory.java | 6 +-
.../seatunnel/file/local/LocalFileFactoryTest.java | 17 ++--
.../file/oss/source/OssFileSourceFactory.java | 6 +-
.../seatunnel/file/oss/OssFileFactoryTest.java | 17 ++--
.../file/s3/source/S3FileSourceFactory.java | 6 +-
.../seatunnel/file/s3/S3FileFactoryTest.java | 17 ++--
.../file/sftp/source/SftpFileSourceFactory.java | 6 +-
.../seatunnel/file/sftp/SftpFileFactoryTest.java | 17 ++--
.../seatunnel/google/sheets/SheetsFactoryTest.java | 15 ++-
.../connectors/seatunnel/hive/HiveFactoryTest.java | 17 ++--
.../seatunnel/http/config/HttpConfig.java | 82 +++++++++-------
.../seatunnel/http/source/HttpSource.java | 12 ++-
.../seatunnel/http/source/HttpSourceFactory.java | 25 +++--
.../connectors/seatunnel/http/HttpFactoryTest.java | 17 ++--
.../gitlab/source/GitlabSourceFactory.java | 5 +-
.../seatunnel/gitlab/GitlabFactoryTest.java | 15 ++-
.../seatunnel/jira/source/JiraSourceFactory.java | 5 +-
.../connectors/seatunnel/jira/JiraFactoryTest.java | 15 ++-
.../klaviyo/source/KlaviyoSourceFactory.java | 29 +++---
.../seatunnel/klaviyo/KlaviyoFactoryTest.java | 15 ++-
.../lemlist/source/LemlistSourceFactory.java | 27 +++---
.../seatunnel/lemlist/LemlistFactoryTest.java | 15 ++-
.../myhours/source/MyHoursSourceFactory.java | 29 +++---
.../seatunnel/myhours/MyHoursFactoryTest.java | 15 ++-
.../onesignal/source/OneSignalSourceFactory.java | 27 +++---
.../seatunnel/onesignal/OneSignalFactoryTest.java | 15 ++-
.../seatunnel/wechat/WeChatFactoryTest.java | 15 ++-
.../seatunnel/iceberg/IcebergFactoryTest.java | 15 ++-
.../seatunnel/influxdb/InfluxDBFactoryTest.java | 17 ++--
.../seatunnel/iotdb/IoTDBFactoryTest.java | 17 ++--
.../connectors/seatunnel/jdbc/JdbcFactoryTest.java | 17 ++--
.../seatunnel/kafka/source/KafkaSourceFactory.java | 8 +-
.../seatunnel/kafka/KafkaFactoryTest.java | 17 ++--
.../connectors/seatunnel/kudu/KuduFactoryTest.java | 17 ++--
.../seatunnel/mongodb/MongodbFactoryTest.java | 17 ++--
.../seatunnel/neo4j/Neo4jFactoryTest.java | 17 ++--
.../openmldb/source/OpenMldbSourceFactory.java | 21 ++---
.../seatunnel/openmldb/OpenMldbFactoryTest.java | 15 ++-
.../pulsar/source/PulsarSourceFactory.java | 6 +-
.../rabbitmq/source/RabbitmqSourceFactory.java | 2 -
.../seatunnel/rabbitmq/RabbitmqFactoryTest.java | 17 ++--
.../seatunnel/redis/source/RedisSourceFactory.java | 3 +-
.../seatunnel/redis/RedisFactoryTest.java | 17 ++--
.../seatunnel/sentry/SentryFactoryTest.java | 15 ++-
.../seatunnel/slack/SlackFactoryTest.java | 15 ++-
.../seatunnel/socket/SocketFactoryTest.java | 17 ++--
.../seatunnel/starrocks/StarRocksFactoryTest.java | 15 ++-
.../tablestore/TablestoreFactoryTest.java | 15 ++-
.../seatunnel/engine/common/config/JobConfig.java | 3 +-
.../engine/server/AbstractSeaTunnelServerTest.java | 5 +-
.../engine/server/master/JobMasterTest.java | 6 +-
.../plugin/discovery/AbstractPluginDiscovery.java | 37 ++------
seatunnel-transforms-v2/pom.xml | 11 +++
.../seatunnel/transform/ReplaceTransform.java | 2 +-
.../transform/ReplaceTransformFactory.java | 8 +-
.../transform/ReplaceTransformFactoryTest.java | 16 ++--
74 files changed, 706 insertions(+), 682 deletions(-)
delete mode 100644
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/util/ExpressionTest.java
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-assert/src/test/java/org/apache/seatunnel/flink/assertion/AssertFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-clickhouse/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseFactoryTest.java
(65%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-console/src/test/java/org/apache/seatunnel/connectors/seatunnel/console/ConsoleFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-datahub/src/test/java/org/apache/seatunnel/connectors/seatunnel/datahub/DataHubFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-dingtalk/src/test/java/org/apache/seatunnel/connectors/seatunnel/DingTalkFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-elasticsearch/src/test/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/ElasticsearchFactoryTest.java
(64%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-email/src/test/java/org/apache/seatunnel/connectors/seatunnel/email/EmailFactoryTest.java
(71%)
copy
seatunnel-connectors-v2/connector-fake/src/{main/java/org/apache/seatunnel/connectors/seatunnel/fake/state/FakeSourceState.java
=>
test/java/org/apache/seatunnel/connectors/seatunnel/fake/FakeFactoryTest.java}
(73%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/FtpFileFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/HdfsFileFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-local/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/local/LocalFileFactoryTest.java
(66%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-oss/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/oss/OssFileFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-s3/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/s3/S3FileFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-file/connector-file-sftp/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/SftpFileFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-google-sheets/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/sheets/SheetsFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-hive/src/test/java/org/apache/seatunnel/connectors/seatunnel/hive/HiveFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/http/HttpFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-gitlab/src/test/java/org/apache/seatunnel/connectors/seatunnel/gitlab/GitlabFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-jira/src/test/java/org/apache/seatunnel/connectors/seatunnel/jira/JiraFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-klaviyo/src/test/java/org/apache/seatunnel/connectors/seatunnel/klaviyo/KlaviyoFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-lemlist/src/test/java/org/apache/seatunnel/connectors/seatunnel/lemlist/LemlistFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-myhours/src/test/java/org/apache/seatunnel/connectors/seatunnel/myhours/MyHoursFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-onesignal/src/test/java/org/apache/seatunnel/connectors/seatunnel/onesignal/OneSignalFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/test/java/org/apache/seatunnel/connectors/seatunnel/wechat/WeChatFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-iceberg/src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-influxdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/influxdb/InfluxDBFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-iotdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/iotdb/IoTDBFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/seatunnel/connectors/seatunnel/kafka/KafkaFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-kudu/src/test/java/org/apache/seatunnel/connectors/seatunnel/kudu/KuduFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-mongodb/src/test/java/org/apache/seatunnel/connectors/seatunnel/mongodb/MongodbFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-neo4j/src/test/java/org/apache/seatunnel/connectors/seatunnel/neo4j/Neo4jFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-openmldb/src/test/java/org/apache/seatunnel/connectors/seatunnel/openmldb/OpenMldbFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-rabbitmq/src/test/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/RabbitmqFactoryTest.java
(67%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-redis/src/test/java/org/apache/seatunnel/connectors/seatunnel/redis/RedisFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-sentry/src/test/java/org/apache/seatunnel/connectors/seatunnel/sentry/SentryFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/SlackFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-socket/src/test/java/org/apache/seatunnel/connectors/seatunnel/socket/SocketFactoryTest.java
(68%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-starrocks/src/test/java/org/apache/seatunnel/connectors/seatunnel/starrocks/StarRocksFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-connectors-v2/connector-tablestore/src/test/java/org/apache/seatunnel/connectors/seatunnel/tablestore/TablestoreFactoryTest.java
(71%)
copy
seatunnel-api/src/test/java/org/apache/seatunnel/api/env/EnvOptionRuleTest.java
=>
seatunnel-transforms-v2/src/test/java/org/apache/seatunnel/transform/ReplaceTransformFactoryTest.java
(71%)