This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch stabilize-metalake-it-timeout
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from a025042dd7 [Test][E2E] Extend Gravitino readiness timeout in MetalakeIT
add c2bd543ffc Connector couchbase migration (#12076)
add 76c22220d7 [Improve][Zeta] Bound the size of a config file uploaded to
the REST server (#12072)
add 0badccfbe2 [Feature][Connector-Kafka] Support Confluent-framed Avro
payloads (#12088)
add 0b559fbf7b [Improve][Zeta] Return the failure message instead of a
stack trace from REST errors (#12070)
add 04fabece50 [Fix][Connector-V2][AmazonSqs] Wrap JSON parse failures
with connector error code (#12085)
add af0a647d27 [Bug][Connector-V2][CDC] Prune removed tables from restored
incremental splits (#11271)
add a0f5a56b86 [Docs][Examples] Add batch MySQL to HDFS partitioned
Parquet example (#11953)
add d3f89cd31c [Fix][Zeta] Propagate interrupted pending job insertion
(#12052)
add c57dfaa8d0 [Feature][Connector-V2] Add Amazon DocumentDB source
connector (#12046)
add c20fefe3bf [Fix][Zeta] Add E2E coverage for telemetry startup deadlock
regression (apache/seatunnel#10840) (#12133)
add 10206bc7aa [Improve][E2E] Validate multi-arch Spark image builds
(#11836)
add 6957d0f134 [Test][E2E] Add regression coverage for
SinkAggregatedCommitterTask checkpoint-cache leak (#12095)
add a8a43cfed4 [Test][E2E] Add regression coverage for slot release after
resource shortfall (#12098)
add b0624cb85d [Test][E2E] Document healthy-pipeline cascade-cancel on
sibling failure (#12100)
add d50f1b6044 [Test][E2E] Add regression coverage for WAIT-strategy
head-of-line blocking (#12103)
add f9184b374a [Test][E2E] Add scale coverage for CoordinatorService
executor growth during mass failover (#12104)
add f977afea04 [Test][E2E] Cover classloader release on failed multi-task
TaskGroup deployment (#12028)
add 5b1f7f70f7 [Test][E2E] Add regression coverage for deploy idempotency
during master failover (#12029)
add aae183be7d [Test][E2E] Add master failover test during source close
handshake (#12031)
add 96836fc68e [Test][E2E] Add regression coverage for master-election
loop retry after transient errors (#12033)
add 2f67a4d948 [Fix][Connector-V2] Fix file content comparison across read
boundaries (#12080)
add 2f7bdb1690 [Docs][Connector-V2] Improve IoTDB Kafka Maxcompute
OceanBase and Oracle connector docs (#11800)
add f0c4590557 [Docs][Connector-V2] Improve Datahub Socket Web3j and
ActiveMQ connector docs (#11788)
add e68e285dde [Test][Zeta] Add E2E coverage for classloader release when
deployLocalTask fails before context publication (apache/seatunnel#11808)
(#12143)
add 0821d8a770 [Test][Zeta] Add E2E coverage for savepoint barrier
injection against a busy source (apache/seatunnel#11473) (#12141)
add af5c3f3101 [Docs] Document S3File credential provider support for
container environments (#11871)
add b59152ffad [Improve][Connector-V2] Validate nonblank Sentry DSN
(#12148)
add 85ed97f4c0 [Docs][Connector-V2] Improve RabbitMQ Milvus and Email
connector docs (#12155)
add 84e43a95b4 [Docs][Connector-V2] Improve InfluxDB Greenplum Mqtt and
Aerospike connector docs (#11722)
add 7a58d1005b [Fix][Connector-V2] Propagate JDBC XA commit failures
(#11569)
add 72acda5704 [Feature][Connector-V2] Add Google Cloud Storage file sink
(#12146)
add c3f79ffb7c [Improve][Connector-V2] Validate nonblank DataHub sink
options (#12174)
add d85d8cc734 [Fix][Connector-V2] Use OAuth token for Slack messages
(#12171)
add 0c7e7f417d [Improve][Connector-V2] Validate DingTalk required options
(#12170)
add 42f1f5491b [Fix][Connector-V2][JDBC][DB2] Read default values as
strings in catalog (#12157)
add d73db95679 [Fix][Connector-V2][JDBC] Use range fallback when
approximate row count is unavailable (#12159)
add e00e1ad721 [Fix][Connector-V2][JDBC][SapHana] Add NCHAR type support
in catalog conversion (#12158)
add 8bea8c681c [Feature][Connector-V2] Support PostgreSQL CDC ADD COLUMN
schema evolution (#11922)
add fdb6beb3ff [Improve][Connector-V2] Validate Typesense connection
options (#12175)
add 30474f8632 [Improve][Connector-V2] Validate OpenMLDB SQL (#12181)
add 271f73324d [Improve][Connector-V2] Validate Web3j source URL (#12180)
add efc81bbb10 [Test][Zeta] Bound finished DAG store benchmark
verification (#12188)
add f6ed9579c5 [Improve][Connector-V2] Add nonblank validation for
required Slack options (#12178)
add c2bb218094 [Improve] Allow committers to bypass the merge queue
(#12198)
add 10ed8d433f [Test][Zeta] Add ProtoStuff serializer microbenchmarks
(#12177)
add 438f9ccfbe [Improve][Zeta] Reduce lock contention in ProtoStuff schema
lookup (#12176)
add 69150256a5 [Test][Connector-V2][Doris] Stabilize flaky
DorisIT.testCustomSql (#12136)
add 6a0f36278d [Feature][CLI] Compare saved benchmark results across
revisions (#12192)
add 1356ec14b9 [Feature][Connector-V2] Add SNMPv2c SET sink connector
(#12011)
add 3db3f0bef8 [Improve][Connector-V2][AmazonSqs] Migrate URL and region
validation to declarative notBlank (#12217)
add 4533d3181b [Docs] Add performance contribution guide (#12214)
add caeb03c8ed [Docs] Refactor Zeta benchmark guide (#12213)
add 47fe784838 [Fix][CI] Fix merge queue bypass actor (#12219)
add 5241d6400f [Test][Zeta] Add E2E coverage for CheckpointMonitorService
startup race (apache/seatunnel#10570) (#12200)
add 91b04d06e4 [Test][E2E] Accept any terminal job state in
CoordinatorExecutorMassFailoverStormIT teardown (#12197)
add b610929289 [Test][Zeta] Add E2E coverage for zombie terminal-state job
cleanup on master switch (apache/seatunnel#10675) (#12184)
add 3a7c1226a5 [Test][E2E] Document dynamic-slot mode granting slots
without capacity rejection (#12106)
add 20900262ee [Test][E2E] Add regression coverage for task stuck in
CANCELING when worker crashes mid-cancel (#12030)
add 55cbbe7fed [Test][Zeta] Add E2E coverage for worker-restart restore
with missing coordinator checkpoint state (apache/seatunnel#11563) (#12183)
add 059b95d7d8 [Test][Zeta] Add E2E coverage for job behavior after a
checkpoint-trigger failure (apache/seatunnel#10442) (#12199)
add 75fd4ed4b2 [Test][E2E] Add E2E test for checkpoint restore with a
corrupted latest checkpoint file (#12110)
add a9cda80f4b [Fix][Zeta] Reuse fixed slots after master failover (#11458)
add 9e02878a4c [Fix][CI] Use SeaTunnel public team for merge queue bypass
(#12229)
add db52cb7b03 [Improve][Connector-V2] Validate nonblank Lance sink
options (#12222)
add ea1fb0d850 [Fix][Connector-V2] Return catalog tables from Aerospike
and SLS sinks (#12234)
add cf67b549a7 [Fix][Transform-V2] Honor Amazon embedding retry options
(#12193)
add 7e468d60f6 [Feature][Connector-V2] Add Google Ads Source Connector
(#12230)
add 313cf73196 [Improve][Connector-V2] Add declarative validation for
Druid sink options (#12250)
add 176870e4ca [Fix][Connector-V2] Complete connector distribution
registrations (#12249)
add 38802bcea2 [Test][Zeta] Add retention-prune on-disk verification for
checkpoint storage (apache/seatunnel#5046) (#12144)
add ff4a0b8ec9 [Fix][Zeta] Ignore duplicate schema change checkpoint
completion (#12150)
add f45b34db06 [Improve][Zeta] Log node tag changes with their previous
value (#12071)
add a55cca1f66 [Improve][Connector-V2] Use HashUtils.bucketIndex in
AzureCosmosDB enumerator (#12049)
add 53333ef488 [Fix][Zeta] Add regression test for finished jobs endpoint
(#11818)
add 3ab7dcde59 [Fix][API] Fix negative queue index when primary key hash
is Integer.MIN_VALUE (#11721)
add 2065fb13fd [Feature][Connector-V2] Support Kafka source connectivity
dry-run (#12167)
add 2531b4ef05 [Improve][Connector-V2][File] Validate anydoc Markdown
handoff (#11813)
add c4c2434235 [Docs][Connector-V2] Improve Aerospike Feishu Mysql GraphQL
and Prometheus connector docs (#11794)
add e3710acba0 [Docs][Connector-V2] Improve Jdbc LocalFile SftpFile
SqlServer-CDC and Opengauss-CDC connector docs (#11761)
add 05472d8bd6 [Fix][Transform-V2] Make rename transform case conversion
locale independent (#11994)
add 98ff97a743 [Test][E2E] Add sustained backpressure IT for fast source
vs slow sink (#12107)
add 3847226697 [Test][E2E] Add regression coverage for duplicate
pending-job dispatch after failover (#12027)
add 9c8052f404 [Feature][Connector-V2] Support multi-table InfluxDB source
(#12247)
add 287288374e [Fix][Transform-V2] Support small integer MOD divisors
(#12215)
add 02b156e457 [Feature][Transform-V2] Add Python transform (#11390)
add a0561d4045 [Fix][Transform-V2] Preserve exact binary value when
CASTing floats to DECIMAL (#11523)
add 09941a1781 [Improve][Connector-V2] Make Couchbase sink readiness
timeout configurable (#12168)
add 708a7b0645 [Fix][Connector-V2][JDBC] Apply where_condition to JDBC
split metadata queries (#12160)
add 70faa7ce50 [Fix][Connector-V2] Honor Oracle snapshot select overrides
(#11768)
add 62efde4746 [Feature][Connector-V2] Add kafka_message_value_fields to
Kafka sink (#11112)
add 5af8d789aa [Fix][Connector-V2] Fix Postgres-CDC committed-offset
recovery skipping rows after savepoint (#11864)
add cc387508c9 [Feature][Connector-V2][MongoDB-CDC] Support timestamp stop
mode (#11815)
add 47fb033fe1 [Fix][Connector-V2] Accept primary keys as snapshot split
columns (#11979)
add 85ce19515b [Feature][Connector-V2] Add zendesk sink (#12253)
add bbde250914 [Fix][CDC] Reconstruct missing snapshot completion
watermark and always wait for a checkpoint (#12162)
add 05620d8b63 [Improve][CI] Stabilize workflow run detection (#11594)
add 6ee0c37447 [Improve][Zeta] Make job detail overview responsive (#12259)
add 56cfbca0fb [Feature] [connector-http-linear] Add Linear HTTP Source
Connector and Unit Test (#12270)
add 7a427d40de [Feature][Connector-V2] Add Facebook Ads source connector
(#12275)
add 7d3649ade2 [Feature][Connector-V2] Add Salesforce sink (#12245)
add 5694541625 Migrated GraphQL according to issue #11007 (#12273)
add 8a1e1de0de [Fix][Core] Propagate transform lifecycle in Flink and
Spark starters (#12263)
add 600797febd [Improve][Connector-V2] Add protobuf format support for
RabbitMQ (#12244)
add 2149f5709e [Feature][Connector-V2] Add TikTok Ads reporting source
(#12283)
add fbc0524d47 [Improve][Connector-V2] Migrate BigQuery validation to
declarative OptionRule (#12272)
add 332d6ac6c0 [Fix][CI] Make ruleset bypass cover full merge gate (#12289)
add ec1b1b8b51 [Fix][CDC][Zeta] Restore runtime schema from checkpoint
after failover (#11503)
add e18b260c0f [Feature][Connector-V2] Support multi-table IoTDB source
(#12246)
add 2ed3c81f53 [Improve][Connector-V2] Migrate S3 Redshift validation to
declarative OptionRule (#12274)
add dab424cd1c [Fix][Zeta] Isolate task cleanup by execution context
(#12238)
add e486ac9ded [Fix][CI] Remove invalid Build ruleset source pin (#12291)
add 0580c092b0 [Fix][Connector-V2] Preserve offset timestamps in
ClickHouse sink statements (#12285)
add d69f5a7848 [Improve][Connector-V2] Add declarative validation for
Google Firestore sink (#12278)
add 857d138ef7 [Improve][Transform-V2] Migrate FilterRowKind validation to
OptionRule (#11763)
add 5e918f399a [Improve] [API] Deprecate Expression in favor of Condition
(#11882)
add 3339132550 [Feature][Connector-V2] Support S3 source connectivity
dry-run (#12242)
add 7b88e18705 feat(connector): add Mem0 Platform V3 ADD sink (#12233)
add 35b2716cde [Fix][CI] Switch minio/minio test containers to the quay.io
mirror (#12287)
add 46e58fc16f [Fix][Zeta] Clean empty checkpoint barrier counters (#12260)
add bd09f6d9ae [Feature][Connector-V2] Support ADD COLUMN schema evolution
for BigQuery (#11577)
add ae9132fe07 [Fix][Zeta] Checkpoint restore remap duplicates subtask
state for parallelism > 1 (#12195)
add 41a9c4b8fb [Improve][Zeta] Apply the finished-jobs page before the
per-job metrics and DAG lookups (#12130)
add 0d9f9e2303 [Fix][CI] Use MinIO mirror for S3 dry-run tests (#12302)
add 38a37104e5 [Fix][Connector-V2] Support secure passive RabbitMQ
connections (#11576)
add f5b7f33e6d [Fix][Zeta] Bound retries for metrics snapshot updates
(#12227)
add 1f29461a75 [Feature][Connector-V2] Add RFC 5424 Syslog sink over TLS
(#12279)
add f4a9665e84 [Feature][Connector-V2] Add Google Analytics 4 report
source (#12280)
add a51712781b [Improve][CI] Run the seatunnel-cli Python test suite in CI
(#12300)
add e86c03e537 [Feature][Connector-V2] Add PayPal Transaction Search
source (#12282)
add 70a6720fc3 [Improve][E2E] Reuse SeaTunnel container for selected test
classes (#11626)
add 60446da971 [Fix][E2E] Unify testcontainers version to 1.21.4 across
all e2e connectors (#11201)
add 0b7fb5ddfa [Feature][Connector-V2][LocalFile] Support append-only text
tailing (#11819)
add 71a3c75183 [Feature][Firebase] sink connector (#12232)
add 3ad49cc2e3 [Docs][Connector-V2] Improve Paimon RocketMQ and Pulsar
connector docs (#12187)
add 75b60fa14e [Fix][Connector-V2][Paimon] Register writer state
serializer (#11978)
add 1325a44b2f [Docs] Add test class conventions to AGENTS.md (#12330)
add b37af3a9bf [Feature] [connector-http] Add Splunk Source Connector and
Unit Tests (#12281)
add 1650a04cdb [Fix][CI] Pin Docker publishing actions to approved SHAs
(#12356)
add eaa6403658 [Docs] Fix option inconsistencies and broken anchors in
connector docs (#12331)
add 42bd53094a [Fix][Connector-V2] Fix JDBC batch data error masking
(#11474)
add 34acb089a3 [Improve][Connector-V2][Prometheus] Retry retryable
remote-write failures and tolerate duplicate/out-of-order rejections (#11974)
add c7304ace6e [Test][Connector-V2] Widen PayPalClientTest's loopback HTTP
wait budget for slower CI runners (#12370)
add f2d726a8e0 [Fix][Build] Enforce consistent line endings (#12379)
add 33f4306497 [Fix][Core] Exclude node_modules from src distribution
(#12389)
add 065a3df4b3 [Fix][Connector-V2] Propagate HTTP sink write failures
(#12312)
add f81e1360e1 [Test][E2E] Start the RocketMQ broker with a single
identity and wait for name-server routes (#12115)
add dd13e2a6f1 [Test][E2E] Count each stored message once in RocketMqIT's
restore verification (#12375)
add a20ac96ef2 [Fix][CI] Give the all-modules unit-test job headroom over
its real duration (#12374)
add febe1f947a [Fix][Connector-File] Clear fileSystem reference on
HadoopFileSystemProxy close (#12369)
add c24e46adfd [Test][CLI] Add opt-in paraphrase benchmark suite (#12241)
add c191297c95 [Test][E2E] Retry NebulaPool init to absorb graphd's
status-vs-RPC-port startup race (#12329)
add 08a38f1b8c [Docs] Document DolphinScheduler integration with Docker
Compose deployments (#11691)
add fc1d08d328 [Fix][E2E] Warm the RocketMQ topic route at every point of
use (#12323)
add ff598706f2 [Fix][Connector-V2] Parse offset timestamps in Iceberg
delete predicates (#12286)
add 455d300283 [Fix][Format] Handle heterogeneous numeric JSON fields
(#11415)
add 9b4814726c [Fix][Zeta] Skip connector jar operations on master-only
nodes (#12023)
add 2f92ff7559 [Test][E2E] Remove RocketMqIT.deleteTopicIfExist, which
never deleted anything (#12393)
add 71860b4469 [Feature][Connector-V2] Support OpenMLDB multi-table source
(#12303)
add 36401ab4bb [Improve][Connector-V2] Use HashUtils.bucketIndex in
AmazonDocumentDB enumerator (#12395)
add 5f7f5c1dbb [Test][E2E] Isolate the RocketMqIT tag tests with unique
topic and consumer group (#12396)
add 957e014f68 [Test][E2E] Add multi-pipeline restore slot-contention
probe for Zeta (#12109)
add 5522f82462 [Fix][Connector-V2] Make MqttSourceConfig serializable
(#12406)
add ea3df16677 [Fix][Connector-V2] Preserve disabled CDC schema behavior
(#12346)
add b70652be8a [Fix][Connector-V2] Surface RocketMQ group-offset lookup
failures instead of rewinding (#12349)
add 36c0d1b8a6 [Fix][E2E] Retry and route-guard the remaining RocketMqIT
offset reads (#12392)
add d710e0678d [Test][Connector-V2] Strengthen the MQTT source
serialization coverage (#12410)
add 6934fd0062 [Improve][Connector-V2] Note the multi-topic early return
in currentOffsets (#12417)
add 398fdfac5c [Improve][Connector-V2] Validate Fluss sink bootstrap
servers (#12422)
add c12764c05b [Fix][Connector-V2] Honor Redis named-user authentication
(#12402)
add 7f7e9a7fc3 [Improve][Connector-V2] Validate Tablestore connection
options (#12424)
add 801e330cba [Test][Connector-V2] Complete the MQTT serialization field
coverage (#12416)
add 0a5c2cc2fc [Fix][Zeta] Render Zeta health metrics with a stable locale
and bound REST fanout (#12161)
add 523d69dbb1 [Feature][Connector-V2] Add OceanBase CDC source connector
(#11060)
add 9604f57227 Merge branch 'dev' into stabilize-metalake-it-timeout
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 35 +-
.gitattributes | 9 +-
.github/workflows/backend.yml | 12 +-
.github/workflows/benchmarks.yml | 1 +
.github/workflows/cli.yml | 101 ++
.github/workflows/labeler/label-scope-conf.yml | 50 +-
.github/workflows/notify_test_workflow.yml | 153 +-
.github/workflows/publish-docker.yaml | 34 +-
.github/workflows/publish-e2e-spark-images.yaml | 22 +-
AGENTS.md | 6 +
config/plugin_config | 19 +
docs/en/ai-cli/benchmark.md | 68 +
docs/en/architecture/engine/resource-management.md | 2 +
docs/en/architecture/features/multi-table.md | 25 +-
docs/en/architecture/transform-plugin-system.md | 1 +
docs/en/connector-v2/source/FacebookAds.md | 169 +++
docs/en/connector-v2/source/GoogleAds.md | 185 +++
docs/en/connector-v2/source/Http-Linear.md | 35 +
.../changelog/connector-amazondocumentdb.md | 24 +
...ector-cdc-db2.md => connector-cdc-oceanbase.md} | 0
.../changelog/connector-google-analytics4.md | 24 +
.../connectors/changelog/connector-http-paypal.md | 5 +
.../connectors/changelog/connector-http-splunk.md | 3 +
.../{connector-snmp.md => connector-mem0.md} | 2 +-
.../connectors/changelog/connector-salesforce.md | 5 +
docs/en/connectors/changelog/connector-snmp.md | 1 +
docs/en/connectors/changelog/connector-syslog.md | 20 +
.../connectors/changelog/connector-tiktok-ads.md | 24 +
docs/en/connectors/connector-faq.md | 2 +-
docs/en/connectors/formats/avro.md | 3 +-
docs/en/connectors/sink/Activemq.md | 25 +
docs/en/connectors/sink/Aerospike.md | 42 +
docs/en/connectors/sink/BigQuery.md | 29 +-
docs/en/connectors/sink/BosFile.md | 2 +-
docs/en/connectors/sink/Clickhouse.md | 8 +
docs/en/connectors/sink/CosFile.md | 2 +-
docs/en/connectors/sink/Couchbase.md | 40 +-
docs/en/connectors/sink/Datahub.md | 15 +
docs/en/connectors/sink/Druid.md | 4 +-
docs/en/connectors/sink/Email.md | 20 +
docs/en/connectors/sink/Firebase.md | 116 ++
docs/en/connectors/sink/Fluss.md | 6 +
docs/en/connectors/sink/FtpFile.md | 2 +-
docs/en/connectors/sink/GcsFile.md | 172 +++
docs/en/connectors/sink/GoogleFirestore.md | 12 +-
docs/en/connectors/sink/Greenplum.md | 8 +-
docs/en/connectors/sink/HdfsFile.md | 2 +-
docs/en/connectors/sink/Http.md | 2 +
docs/en/connectors/sink/HugeGraph.md | 4 +-
docs/en/connectors/sink/Iceberg.md | 4 +
docs/en/connectors/sink/InfluxDB.md | 37 +
docs/en/connectors/sink/IoTDBv2.md | 6 +-
docs/en/connectors/sink/Jdbc.md | 65 +-
docs/en/connectors/sink/Kafka.md | 1 +
docs/en/connectors/sink/Lance.md | 4 +
docs/en/connectors/sink/LocalFile.md | 2 +-
docs/en/connectors/sink/Mem0.md | 33 +
docs/en/connectors/sink/Milvus.md | 16 +
docs/en/connectors/sink/Oracle.md | 2 +-
docs/en/connectors/sink/OssFile.md | 2 +-
docs/en/connectors/sink/OssJindoFile.md | 2 +-
docs/en/connectors/sink/Paimon.md | 20 +
docs/en/connectors/sink/Prometheus.md | 34 +-
docs/en/connectors/sink/Pulsar.md | 14 +
docs/en/connectors/sink/Rabbitmq.md | 74 +
docs/en/connectors/sink/Redis.md | 13 +
docs/en/connectors/sink/RocketMQ.md | 16 +-
docs/en/connectors/sink/S3File.md | 105 +-
docs/en/connectors/sink/SNMP.md | 137 ++
docs/en/connectors/sink/Salesforce.md | 157 +++
docs/en/connectors/sink/SftpFile.md | 2 +-
docs/en/connectors/sink/Socket.md | 15 +
docs/en/connectors/sink/Syslog.md | 170 +++
docs/en/connectors/sink/Tablestore.md | 1 +
docs/en/connectors/sink/Zendesk.md | 132 ++
docs/en/connectors/source/AmazonDocumentDB.md | 231 ++++
docs/en/connectors/source/GoogleAnalytics4.md | 191 +++
docs/en/connectors/source/Greenplum.md | 14 +-
docs/en/connectors/source/InfluxDB.md | 138 +-
docs/en/connectors/source/IoTDB.md | 49 +-
docs/en/connectors/source/Jdbc.md | 43 +
docs/en/connectors/source/Kafka.md | 26 +-
docs/en/connectors/source/LocalFile.md | 90 +-
docs/en/connectors/source/Maxcompute.md | 2 +-
docs/en/connectors/source/Milvus.md | 20 +
docs/en/connectors/source/MongoDB-CDC.md | 42 +
docs/en/connectors/source/Mqtt.md | 34 +-
docs/en/connectors/source/ObsFile.md | 14 +-
docs/en/connectors/source/OceanBase-CDC.md | 119 ++
docs/en/connectors/source/OpenMldb.md | 88 +-
docs/en/connectors/source/Opengauss-CDC.md | 26 +-
docs/en/connectors/source/Oracle-CDC.md | 11 +
docs/en/connectors/source/OssFile.md | 2 +-
docs/en/connectors/source/Paimon.md | 20 +
docs/en/connectors/source/PayPal.md | 107 ++
docs/en/connectors/source/Persistiq.md | 4 +-
docs/en/connectors/source/PostgreSQL-CDC.md | 26 +
docs/en/connectors/source/Prometheus.md | 5 +-
docs/en/connectors/source/Pulsar.md | 20 +
docs/en/connectors/source/Rabbitmq.md | 84 ++
docs/en/connectors/source/Redis.md | 12 +-
docs/en/connectors/source/RocketMQ.md | 16 +-
docs/en/connectors/source/S3File.md | 139 ++
docs/en/connectors/source/SftpFile.md | 99 ++
docs/en/connectors/source/Socket.md | 15 +
docs/en/connectors/source/Splunk.md | 54 +
docs/en/connectors/source/SqlServer-CDC.md | 107 +-
docs/en/connectors/source/Tablestore.md | 1 +
docs/en/connectors/source/TikTokAds.md | 159 +++
docs/en/connectors/source/Web3j.md | 17 +
docs/en/developer/anydoc-document-parser-poc.md | 75 +
docs/en/developer/contribute-performance-guide.md | 96 ++
docs/en/developer/contribution-path.md | 15 +
docs/en/edge-agent/configuration.md | 6 +-
docs/en/edge-agent/faq.md | 4 +-
docs/en/edge-agent/input-configuration.md | 2 +-
docs/en/edge-agent/output-configuration.md | 2 +-
docs/en/edge-agent/quick-start.md | 8 +-
docs/en/engines/zeta/benchmark.md | 565 +++-----
docs/en/engines/zeta/checkpoint-storage.md | 2 +
docs/en/engines/zeta/hybrid-cluster-deployment.md | 8 +
docs/en/engines/zeta/rest-api-v1.md | 3 +
docs/en/engines/zeta/rest-api-v2.md | 36 +-
.../engines/zeta/separated-cluster-deployment.md | 8 +
docs/en/engines/zeta/telemetry.md | 8 +
docs/en/engines/zeta/user-command.md | 2 +
docs/en/getting-started/recipes/mysql-to-hdfs.md | 215 +++
docs/en/getting-started/recipes/overview.md | 1 +
.../introduction/concepts/incompatible-changes.md | 70 +
.../configuration/config-encryption-decryption.md | 2 +-
.../introduction/configuration/schema-evolution.md | 1 +
docs/en/tools/dolphinscheduler-integration.md | 90 ++
docs/en/transforms/embedding.md | 7 +-
docs/en/transforms/python.md | 173 +++
docs/sidebars.js | 6 +-
docs/zh/ai-cli/benchmark.md | 60 +
docs/zh/architecture/engine/resource-management.md | 2 +
docs/zh/architecture/features/multi-table.md | 16 +-
docs/zh/architecture/transform-plugin-system.md | 1 +
docs/zh/connector-v2/source/FacebookAds.md | 162 +++
docs/zh/connector-v2/source/GoogleAds.md | 179 +++
.../changelog/connector-amazondocumentdb.md | 24 +
.../changelog/connector-cdc-oceanbase.md | 6 +
.../changelog/connector-google-analytics4.md | 24 +
.../connectors/changelog/connector-http-paypal.md | 5 +
.../connectors/changelog/connector-mem0.md} | 2 +-
.../connectors/changelog/connector-salesforce.md | 5 +
docs/zh/connectors/changelog/connector-snmp.md | 1 +
docs/zh/connectors/changelog/connector-syslog.md | 20 +
.../connectors/changelog/connector-tiktok-ads.md | 24 +
docs/zh/connectors/connector-faq.md | 20 +-
docs/zh/connectors/formats/avro.md | 3 +-
docs/zh/connectors/sink/Activemq.md | 19 +
docs/zh/connectors/sink/Aerospike.md | 10 +-
docs/zh/connectors/sink/BigQuery.md | 29 +-
docs/zh/connectors/sink/BosFile.md | 4 +-
docs/zh/connectors/sink/Clickhouse.md | 8 +
docs/zh/connectors/sink/Couchbase.md | 35 +-
docs/zh/connectors/sink/Datahub.md | 15 +
docs/zh/connectors/sink/Druid.md | 4 +-
docs/zh/connectors/sink/Email.md | 20 +
docs/zh/connectors/sink/Feishu.md | 97 +-
docs/zh/connectors/sink/Firebase.md | 117 ++
docs/zh/connectors/sink/Fluss.md | 6 +
docs/zh/connectors/sink/GcsFile.md | 165 +++
docs/zh/connectors/sink/GoogleFirestore.md | 12 +-
docs/zh/connectors/sink/Http.md | 2 +
docs/zh/connectors/sink/HugeGraph.md | 4 +-
docs/zh/connectors/sink/Iceberg.md | 4 +
docs/zh/connectors/sink/IoTDBv2.md | 6 +-
docs/zh/connectors/sink/Jdbc.md | 14 +-
docs/zh/connectors/sink/Kafka.md | 1 +
docs/zh/connectors/sink/Lance.md | 4 +
docs/zh/connectors/sink/Mem0.md | 30 +
docs/zh/connectors/sink/Milvus.md | 16 +
docs/zh/connectors/sink/Mysql.md | 8 +-
docs/zh/connectors/sink/Oracle.md | 2 +-
docs/zh/connectors/sink/OssJindoFile.md | 2 +-
docs/zh/connectors/sink/Paimon.md | 20 +
docs/zh/connectors/sink/Prometheus.md | 6 +-
docs/zh/connectors/sink/Pulsar.md | 14 +
docs/zh/connectors/sink/Rabbitmq.md | 74 +
docs/zh/connectors/sink/Redis.md | 12 +
docs/zh/connectors/sink/RocketMQ.md | 16 +-
docs/zh/connectors/sink/S3File.md | 103 ++
docs/zh/connectors/sink/SNMP.md | 135 ++
docs/zh/connectors/sink/Salesforce.md | 138 ++
docs/zh/connectors/sink/Socket.md | 15 +
docs/zh/connectors/sink/Syslog.md | 166 +++
docs/zh/connectors/sink/Tablestore.md | 1 +
docs/zh/connectors/sink/Zendesk.md | 129 ++
docs/zh/connectors/source/AmazonDocumentDB.md | 231 ++++
docs/zh/connectors/source/BosFile.md | 2 +-
docs/zh/connectors/source/FakeSource.md | 2 +-
docs/zh/connectors/source/GcsFile.md | 2 +-
docs/zh/connectors/source/GoogleAnalytics4.md | 179 +++
docs/zh/connectors/source/GraphQL.md | 90 ++
docs/zh/connectors/source/Greenplum.md | 8 +-
docs/zh/connectors/source/Hbase.md | 2 +-
docs/zh/connectors/source/InfluxDB.md | 68 +-
docs/zh/connectors/source/IoTDB.md | 49 +-
docs/zh/connectors/source/Kafka.md | 27 +-
docs/zh/connectors/source/LocalFile.md | 44 +-
docs/zh/connectors/source/Maxcompute.md | 2 +-
docs/zh/connectors/source/Milvus.md | 20 +
docs/zh/connectors/source/MongoDB-CDC.md | 42 +
docs/zh/connectors/source/ObsFile.md | 2 +-
docs/zh/connectors/source/OceanBase-CDC.md | 117 ++
docs/zh/connectors/source/OpenMldb.md | 81 +-
docs/zh/connectors/source/Oracle-CDC.md | 11 +
docs/zh/connectors/source/OssFile.md | 2 +-
docs/zh/connectors/source/OssJindoFile.md | 2 +-
docs/zh/connectors/source/Paimon.md | 20 +
docs/zh/connectors/source/PayPal.md | 107 ++
docs/zh/connectors/source/Persistiq.md | 6 +-
docs/zh/connectors/source/PostgreSQL-CDC.md | 24 +
docs/zh/connectors/source/Prometheus.md | 70 +
docs/zh/connectors/source/Pulsar.md | 20 +
docs/zh/connectors/source/Rabbitmq.md | 83 ++
docs/zh/connectors/source/Redis.md | 10 +-
docs/zh/connectors/source/RocketMQ.md | 16 +-
docs/zh/connectors/source/S3File.md | 131 ++
docs/zh/connectors/source/Socket.md | 15 +
docs/zh/connectors/source/Tablestore.md | 1 +
docs/zh/connectors/source/TikTokAds.md | 142 ++
docs/zh/connectors/source/Typesense.md | 2 +-
docs/zh/connectors/source/Web3j.md | 17 +
docs/zh/developer/anydoc-document-parser-poc.md | 75 +
docs/zh/developer/contribute-performance-guide.md | 87 ++
docs/zh/developer/contribution-path.md | 15 +
docs/zh/edge-agent/configuration.md | 6 +-
docs/zh/edge-agent/faq.md | 4 +-
docs/zh/edge-agent/input-configuration.md | 2 +-
docs/zh/edge-agent/output-configuration.md | 2 +-
docs/zh/edge-agent/quick-start.md | 8 +-
docs/zh/engines/zeta/benchmark.md | 519 +++----
docs/zh/engines/zeta/checkpoint-storage.md | 2 +
docs/zh/engines/zeta/hybrid-cluster-deployment.md | 8 +
docs/zh/engines/zeta/log-analysis-with-ai.md | 2 +-
docs/zh/engines/zeta/rest-api-v1.md | 3 +
docs/zh/engines/zeta/rest-api-v2.md | 32 +-
.../engines/zeta/separated-cluster-deployment.md | 8 +
docs/zh/engines/zeta/telemetry.md | 6 +
docs/zh/engines/zeta/user-command.md | 2 +
docs/zh/getting-started/recipes/mysql-to-hdfs.md | 215 +++
docs/zh/getting-started/recipes/overview.md | 1 +
.../introduction/concepts/incompatible-changes.md | 58 +
.../introduction/configuration/schema-evolution.md | 1 +
docs/zh/tools/dolphinscheduler-integration.md | 90 ++
docs/zh/transforms/embedding.md | 6 +-
docs/zh/transforms/python.md | 173 +++
mvnw | 22 +-
plugin-mapping.properties | 17 +
pom.xml | 2 +-
.../api/configuration/util/Expression.java | 12 +
.../api/configuration/util/RequiredOption.java | 7 +
.../org/apache/seatunnel/api/event/EventType.java | 1 +
.../sink/multitablesink/MultiTableSinkWriter.java | 9 +-
.../schema/event/RestoreTableSchemaEvent.java | 58 +
.../handler/AlterTableSchemaEventHandler.java | 4 +
.../handler/DataTypeChangeEventDispatcher.java | 4 +
.../handler/TableSchemaChangeEventDispatcher.java | 4 +
.../multitablesink/MultiTableSinkWriterTest.java | 94 ++
.../handler/RestoreTableSchemaEventTest.java | 111 ++
seatunnel-benchmarks/README.md | 6 +
.../benchmark/IMapDagStorageBenchmark.java | 6 +-
.../benchmark/ProtoStuffSerializerBenchmark.java | 97 ++
.../imap/IMapDagStorageBenchmarkWorkload.java | 24 +-
.../ProtoStuffSerializerBenchmarkTest.java | 100 ++
.../imap/IMapDagStorageBenchmarkWorkloadTest.java | 262 ++++
.../imap/IMapDagStoragePersistenceTest.java | 120 ++
seatunnel-cli/benchmark/README.md | 106 +-
seatunnel-cli/benchmark/compare.py | 386 ++++++
seatunnel-cli/benchmark/docker/docker-compose.yml | 4 +-
seatunnel-cli/benchmark/paraphrases.py | 73 +
seatunnel-cli/benchmark/runner.py | 68 +-
seatunnel-cli/benchmark/tasks/paraphrase.json | 81 ++
seatunnel-cli/pyproject.toml | 11 +-
seatunnel-cli/tests/test_benchmark_comparison.py | 583 ++++++++
seatunnel-cli/tests/test_benchmark_paraphrases.py | 386 ++++++
.../seatunnel/aerospike/sink/AerospikeSink.java | 12 +-
.../pom.xml | 25 +-
.../config/AmazonDocumentDBConfig.java | 275 ++++
.../config/AmazonDocumentDBSourceOptions.java | 77 ++
.../serialize/DocumentDBItemDeserializer.java | 240 ++++
.../source/AmazonDocumentDBSource.java | 90 ++
.../source/AmazonDocumentDBSourceFactory.java | 77 ++
.../source/AmazonDocumentDBSourceReader.java | 221 +++
.../source/AmazonDocumentDBSourceSplit.java | 62 +
.../AmazonDocumentDBSourceSplitEnumerator.java | 201 +++
.../source/AmazonDocumentDBSourceState.java | 66 +
.../AmazonDocumentDBSourceFactoryTest.java | 55 +
.../DocumentDBItemDeserializerTest.java | 181 +++
.../config/AmazonDocumentDBConfigTest.java | 134 ++
.../source/AmazonDocumentDBSourceReaderTest.java | 301 ++++
.../AmazonDocumentDBSourceSplitEnumeratorTest.java | 230 ++++
.../deserialize/AmazonSqsDeserializer.java | 34 +-
.../amazonsqs/sink/AmazonSqsSinkFactory.java | 4 +-
.../amazonsqs/source/AmazonSqsSourceFactory.java | 5 +-
.../amazonsqs/AmazonSqsSourceFactoryTest.java | 95 +-
.../amazonsqs/sink/AmazonSqsSinkFactoryTest.java | 100 ++
.../source/AmazonSqsSourceReaderTest.java | 75 +
.../source/AzureCosmosDBSourceSplitEnumerator.java | 3 +-
.../AzureCosmosDBSourceSplitEnumeratorTest.java | 44 +
seatunnel-connectors-v2/connector-bigquery/pom.xml | 6 +-
.../bigquery/catalog/BigQueryCatalog.java | 13 +
.../bigquery/client/BigQueryClientFactory.java | 12 +-
.../bigquery/convert/BigQuerySerializer.java | 5 +-
.../exception/BigQueryConnectorErrorCode.java | 1 +
.../bigquery/option/BigQuerySinkOptions.java | 24 +-
.../schema/BigQuerySchemaChangeManager.java | 480 +++++++
.../bigquery/schema/BigQueryTypeConverter.java | 158 +++
.../bigquery/sink/AbstractBigQuerySinkWriter.java | 196 ++-
.../bigquery/sink/BigQuerySaveModeHandler.java | 7 +
.../connectors/bigquery/sink/BigQuerySink.java | 31 +-
.../bigquery/sink/BigQuerySinkBatchWriter.java | 14 +-
.../bigquery/sink/BigQuerySinkFactory.java | 35 +-
.../bigquery/sink/BigQuerySinkStreamWriter.java | 12 +-
.../bigquery/sink/writer/BigQueryBatchWriter.java | 22 +-
.../bigquery/sink/writer/BigQueryStreamWriter.java | 20 +-
.../bigquery/sink/writer/BigQueryWriter.java | 18 +
.../bigquery/sink/writer/TableSchemaUtil.java | 49 +-
.../schema/BigQuerySchemaChangeManagerTest.java | 539 ++++++++
.../bigquery/schema/BigQueryTypeConverterTest.java | 63 +
.../sink/BigQueryCatalogAndSaveModeTest.java | 103 ++
.../bigquery/sink/BigQuerySinkFactoryTest.java | 116 +-
.../sink/BigQuerySinkSchemaEvolutionTest.java | 279 ++++
.../connectors/cdc/base/config/StopConfig.java | 2 +-
.../cdc/base/dialect/DataSourceDialect.java | 15 +
.../cdc/base/schema/SchemaChangeResolver.java | 10 +
.../enumerator/IncrementalSplitAssigner.java | 6 +
.../source/enumerator/SnapshotSplitAssigner.java | 53 +-
.../splitter/AbstractJdbcSourceChunkSplitter.java | 18 +-
.../source/reader/IncrementalSourceReader.java | 164 ++-
.../external/IncrementalSourceStreamFetcher.java | 6 +-
.../cdc/base/source/split/IncrementalSplit.java | 66 +
.../cdc/base/utils/SourceRecordUtils.java | 5 +-
.../AbstractDebeziumDeserializationSchema.java | 30 +-
.../debezium/DebeziumDeserializationSchema.java | 11 +
.../row/SeaTunnelRowDebeziumDeserializeSchema.java | 39 +-
.../jdbc/source/JdbcSourceChunkSplitterTest.java | 18 +
.../enumerator/IncrementalSplitAssignerTest.java | 90 +-
.../enumerator/SnapshotSplitAssignerTest.java | 73 +-
.../source/reader/IncrementalSourceReaderTest.java | 378 +++++
.../IncrementalSourceStreamFetcherTest.java | 80 ++
.../base/source/split/IncrementalSplitTest.java | 189 +++
.../AbstractDebeziumDeserializationSchemaTest.java | 76 +
...nelRowDebeziumDeserializeSchemaRestoreTest.java | 104 ++
.../seatunnel/cdc/db2/source/Db2Dialect.java | 12 +
.../source/Db2IncrementalSourceFactoryTest.java | 21 +
.../cdc/mongodb/MongodbIncrementalSource.java | 5 +-
.../mongodb/MongodbIncrementalSourceFactory.java | 6 +
.../config/MongodbIncrementalSourceOptions.java | 9 +-
.../config/MongodbSourceConfigProvider.java | 28 +-
.../source/fetch/MongodbStreamFetchTask.java | 13 +-
.../MongodbIncrementalSourceFactoryTest.java | 125 ++
.../source/fetch/MongodbStreamFetchTaskTest.java} | 16 +-
.../source/MySqlIncrementalSourceFactory.java | 108 +-
.../connector-cdc/connector-cdc-oceanbase}/pom.xml | 19 +-
.../source/OceanBaseIncrementalSource.java | 59 +
.../source/OceanBaseIncrementalSourceFactory.java | 123 ++
.../OceanBaseIncrementalSourceFactoryTest.java | 109 ++
.../fetch/scan/OracleSnapshotSplitReadTask.java | 3 +-
.../seatunnel/cdc/oracle/utils/OracleUtils.java | 82 +-
.../cdc/oracle/utils/OracleUtilsTest.java | 29 +
.../connector/postgresql/PostgresObjectUtils.java | 6 +-
.../postgresql/RelationAwarePostgresSchema.java | 96 ++
.../config/PostgresSourceConfigFactory.java | 6 +-
.../cdc/postgres/source/PostgresDialect.java | 9 +-
.../postgres/source/PostgresIncrementalSource.java | 35 +-
.../source/PostgresIncrementalSourceFactory.java | 23 +-
.../PostgresRelationSchemaChangeResolver.java | 206 +++
.../source/PostgresRelationSchemaRecord.java | 74 +
.../cdc/postgres/source/offset/LsnOffset.java | 14 +
.../reader/PostgresSourceFetchTaskContext.java | 76 +-
.../source/reader/wal/PostgresWalFetchTask.java | 14 +-
.../cdc/postgres/utils/PostgresTypeUtils.java | 20 +-
...tgresIncrementalSourceSchemaEvolutionTest.java} | 28 +-
.../PostgresRelationSchemaChangeResolverTest.java | 226 +++
.../cdc/postgres/source/offset/LsnOffsetTest.java | 38 +
seatunnel-connectors-v2/connector-cdc/pom.xml | 1 +
.../executor/FieldNamedPreparedStatement.java | 21 +-
.../JdbcBatchStatementExecutorBuilder.java | 19 +-
.../sink/client/executor/JdbcRowConverter.java | 31 +
.../sink/inject/OffsetDateTimeInjectFunction.java | 62 +
.../sink/client/executor/JdbcRowConverterTest.java | 204 +++
.../couchbase/config/CouchbaseSinkOptions.java | 22 +-
.../couchbase/sink/CouchbaseSinkFactory.java | 8 +-
.../seatunnel/couchbase/sink/CouchbaseWriter.java | 144 +-
.../couchbase/sink/CouchbaseWriterOptions.java | 33 +-
.../couchbase/sink/CouchbaseSinkFactoryTest.java | 157 +++
.../couchbase/sink/CouchbaseWriterCloseTest.java | 256 ----
.../sink/CouchbaseWriterConstructorLeakTest.java | 40 +-
.../couchbase/sink/CouchbaseWriterOptionsTest.java | 77 ++
.../couchbase/sink/CouchbaseWriterTest.java | 250 ++++
.../sink/DatabendSinkAggregatedCommitter.java | 18 +-
.../databend/sink/DatabendSinkCommitterInfo.java | 20 +
.../databend/sink/DatabendSinkWriter.java | 20 +-
.../databend/sink/DatabendSinkWriterTest.java | 75 +
.../seatunnel/datahub/sink/DataHubSinkFactory.java | 7 +-
.../seatunnel/datahub/DataHubFactoryTest.java | 72 +-
.../seatunnel/sink/DingTalkSinkFactory.java | 6 +-
.../connectors/seatunnel/DingTalkFactoryTest.java | 50 +-
.../doris/sink/writer/DorisSinkWriter.java | 18 +-
.../connectors/druid/sink/DruidSinkFactory.java | 7 +-
.../seatunnel/druid/DruidFactoryTest.java | 90 +-
.../sink/ElasticsearchSinkWriter.java | 3 +
.../connector-facebook-ads/pom.xml | 55 +
.../facebook/ads/client/FacebookAdsClient.java | 254 ++++
.../facebook/ads/config/FacebookAdsParameters.java | 48 +
.../ads/config/FacebookAdsSourceOptions.java | 127 ++
.../ads/config/FacebookAdsTableConfig.java | 58 +
.../exception/FacebookAdsConnectorErrorCode.java} | 13 +-
.../exception/FacebookAdsConnectorException.java} | 28 +-
.../facebook/ads/source/FacebookAdsSource.java | 262 ++++
.../ads/source/FacebookAdsSourceFactory.java} | 43 +-
.../ads/source/FacebookAdsSourceReader.java | 92 ++
.../facebook/ads/FacebookAdsSourceFactoryTest.java | 160 +++
.../facebook/ads/client/FacebookAdsClientTest.java | 278 ++++
.../facebook/ads/source/FacebookAdsSourceTest.java | 246 ++++
.../file/hadoop/HadoopFileSystemProxy.java | 19 +-
.../file/sink/writer/AbstractWriteStrategy.java | 34 +-
.../seatunnel/file/source/LocalFileIdentity.java | 116 ++
.../file/source/event/FileSplitFinishedEvent.java | 9 +-
.../file/source/reader/AbstractReadStrategy.java | 20 +-
.../file/source/reader/MarkdownReadStrategy.java | 60 +-
.../reader/MultipleTableFileSourceReader.java | 85 +-
.../seatunnel/file/source/reader/ReadStrategy.java | 9 +
.../file/source/reader/TextReadStrategy.java | 46 +-
...uousMultipleTableFileSourceSplitEnumerator.java | 586 +++++++-
.../file/source/split/FileSourceSplit.java | 31 +-
.../file/source/state/FileSourceState.java | 109 +-
.../seatunnel/file/source/state/FileTailState.java | 53 +
.../hadoop/ChunkedInputHadoopFileSystemProxy.java | 120 ++
.../file/hadoop/HadoopFileSystemProxyTest.java | 64 +
.../file/reader/StreamLineSplitterTest.java | 16 +
.../file/source/LocalFileIdentityTest.java | 116 ++
.../source/reader/MarkdownReadStrategyTest.java | 112 ++
.../reader/MultipleTableFileSourceReaderTest.java | 338 +++++
.../reader/ReadStrategySplitFallbackTest.java | 31 +
.../file/source/reader/UpdateSyncModeTest.java | 79 ++
...MultipleTableFileSourceSplitEnumeratorTest.java | 1089 +++++++++++++++
.../FileSourceSerializationCompatibilityTest.java | 208 +++
.../file/writer/FileSchemaEvolutionTest.java | 49 +
.../src/test/resources/anydoc/test_read_excel.md | 7 +
.../seatunnel/file/gcs/catalog/GcsFileCatalog.java | 44 +
.../file/gcs/catalog/GcsFileCatalogFactory.java | 55 +
.../file/gcs/config/GcsFileSinkOptions.java | 11 +-
.../seatunnel/file/gcs/sink/GcsFileSink.java} | 31 +-
.../file/gcs/sink/GcsFileSinkFactory.java | 158 +++
.../seatunnel/file/gcs/GcsFileSinkFactoryTest.java | 188 +++
.../file/gcs/catalog/GcsFileCatalogTest.java | 106 ++
.../file/s3/source/S3FileSourceFactory.java | 19 +-
.../file/s3/source/S3SourceDryRunValidator.java | 284 ++++
.../seatunnel/file/s3/S3FileSourceFactoryTest.java | 8 +
.../s3/source/S3SourceDryRunValidatorTest.java | 463 +++++++
seatunnel-connectors-v2/connector-firebase/pom.xml | 6 +
.../firebase/client/FirebaseHttpClient.java | 85 +-
...SourceOptions.java => FirebaseBaseOptions.java} | 13 +-
.../firebase/config/FirebaseSinkOptions.java | 70 +
.../firebase/config/FirebaseSourceOptions.java | 35 +-
.../seatunnel/firebase/sink/FirebaseSink.java} | 29 +-
.../firebase/sink/FirebaseSinkFactory.java} | 31 +-
.../firebase/sink/FirebaseSinkWriter.java | 261 ++++
.../firebase/sink/FirebaseSinkWriterTest.java | 457 ++++++
.../seatunnel/fluss/sink/FlussSinkFactory.java | 5 +-
.../seatunnel/fluss/sink/FlussSinkFactoryTest.java | 67 +
.../connector-google-ads/pom.xml | 55 +
.../google/ads/client/GoogleAdsClient.java | 402 ++++++
.../google/ads/config/GoogleAdsParameters.java | 59 +
.../google/ads/config/GoogleAdsSourceOptions.java | 160 +++
.../google/ads/config/GoogleAdsTableConfig.java} | 45 +-
.../exception/GoogleAdsConnectorErrorCode.java} | 14 +-
.../exception/GoogleAdsConnectorException.java} | 27 +-
.../google/ads/source/GoogleAdsSource.java | 251 ++++
.../google/ads/source/GoogleAdsSourceFactory.java} | 49 +-
.../google/ads/source/GoogleAdsSourceReader.java | 98 ++
.../google/ads/GoogleAdsSourceFactoryTest.java | 209 +++
.../google/ads/client/GoogleAdsClientTest.java | 418 ++++++
.../google/ads/source/GoogleAdsSourceTest.java | 296 ++++
.../connector-google-analytics4/pom.xml | 105 ++
.../google/analytics4/GoogleAnalytics4Config.java | 201 +++
.../analytics4/GoogleAnalytics4HttpTransport.java | 278 ++++
.../google/analytics4/GoogleAnalytics4Report.java | 319 +++++
.../google/analytics4/GoogleAnalytics4Source.java | 67 +
.../analytics4/GoogleAnalytics4SourceFactory.java} | 45 +-
.../analytics4/GoogleAnalytics4SourceOptions.java | 114 ++
.../analytics4/GoogleAnalytics4SourceReader.java | 260 ++++
.../analytics4/GoogleAnalytics4ReportTest.java | 336 +++++
.../GoogleAnalytics4SourceReaderTest.java | 490 +++++++
.../TestGoogleAnalytics4PackagingIT.java | 208 +++
.../firestore/sink/FirestoreSinkFactory.java | 7 +-
.../google/firestore/FirestoreFactoryTest.java | 91 +-
.../seatunnel/graphql/sink/GraphQLSinkFactory.java | 4 +-
.../graphql/source/GraphQLSourceFactory.java | 4 +-
.../seatunnel/graphql/util/GraphQLUtil.java | 10 -
.../seatunnel/http/sink/HttpSinkWriter.java | 28 +-
.../http/sink/HttpSinkBatchWriterTest.java | 40 +
.../connector-http/connector-http-linear}/pom.xml | 21 +-
.../connectors/seatunnel/linear/LinearSource.java | 56 +
.../seatunnel/linear/LinearSourceFactory.java} | 26 +-
.../linear/config/LinearSourceOptions.java} | 18 +-
.../linear/config/LinearSourceParameter.java} | 25 +-
.../seatunnel/linear/LinearSourceFactoryTest.java | 47 +
.../connector-http/connector-http-paypal}/pom.xml | 21 +-
.../seatunnel/paypal/source/PayPalClient.java | 296 ++++
.../seatunnel/paypal/source/PayPalConfig.java | 155 +++
.../seatunnel/paypal/source/PayPalResponse.java | 168 +++
.../seatunnel/paypal/source/PayPalSource.java | 100 ++
.../paypal/source/PayPalSourceFactory.java} | 34 +-
.../paypal/source/PayPalSourceOptions.java | 85 ++
.../paypal/source/PayPalSourceReader.java | 95 ++
.../seatunnel/paypal/source/PayPalClientTest.java | 496 +++++++
.../paypal/source/PayPalResponseTest.java | 402 ++++++
.../paypal/source/TestPayPalPackagingIT.java | 141 ++
.../connector-http/connector-http-splunk}/pom.xml | 20 +-
.../connectors/seatunnel/splunk/SplunkSource.java | 55 +
.../seatunnel/splunk/SplunkSourceFactory.java} | 30 +-
.../seatunnel/splunk/SplunkSourceReader.java | 118 ++
.../splunk/config/SplunkSourceOptions.java | 41 +
.../splunk/config/SplunkSourceParameter.java | 68 +
.../seatunnel/splunk/SplunkSourceFactoryTest.java | 142 ++
.../seatunnel/splunk/SplunkSourceReaderTest.java | 76 +
.../seatunnel/zendesk/config/ZendeskConfig.java | 83 ++
.../seatunnel/zendesk/sink/ZendeskSink.java | 84 ++
.../zendesk/sink/ZendeskSinkFactory.java} | 27 +-
.../seatunnel/zendesk/sink/ZendeskSinkWriter.java | 233 ++++
.../config/ZendeskSinkOptions.java} | 26 +-
.../source/config/ZendeskSourceOptions.java | 23 +-
.../zendesk/sink/ZendeskSinkFactoryTest.java} | 13 +-
.../zendesk/sink/ZendeskSinkWriterTest.java | 371 +++++
.../connector-http/connector-mem0/pom.xml | 35 +
.../seatunnel/mem0/config/Mem0SinkOptions.java | 68 +
.../connectors/seatunnel/mem0/sink/Mem0Sink.java | 94 ++
.../seatunnel/mem0/sink/Mem0SinkFactory.java} | 29 +-
.../seatunnel/mem0/sink/Mem0SinkWriter.java | 193 +++
.../seatunnel/mem0/sink/Mem0SinkWriterTest.java | 166 +++
seatunnel-connectors-v2/connector-http/pom.xml | 4 +
.../seatunnel/iceberg/sink/IcebergSinkWriter.java | 10 +-
.../seatunnel/iceberg/utils/ExpressionUtils.java | 17 +
.../catalog/IcebergTimestampDeleteTest.java | 161 +++
.../iceberg/utils/ExpressionUtilsTest.java | 102 ++
.../seatunnel/influxdb/source/InfluxDBSource.java | 26 +-
.../influxdb/source/InfluxDBSourceFactory.java | 176 ++-
.../influxdb/source/InfluxDBSourceSplit.java | 10 +
.../source/InfluxDBSourceSplitEnumerator.java | 69 +-
.../influxdb/source/InfluxDBSourceTable.java} | 31 +-
.../influxdb/source/InfluxdbSourceReader.java | 76 +-
.../source/InfluxDBMultiTableSourceTest.java | 555 ++++++++
.../seatunnel/iotdb/source/IoTDBSource.java | 16 +-
.../seatunnel/iotdb/source/IoTDBSourceFactory.java | 156 ++-
.../seatunnel/iotdb/source/IoTDBSourceReader.java | 36 +-
.../seatunnel/iotdb/source/IoTDBSourceSplit.java | 11 +
.../iotdb/source/IoTDBSourceSplitEnumerator.java | 43 +-
.../seatunnel/iotdb/IoTDBFactoryTest.java | 102 ++
.../iotdb/source/IoTDBMultiTableSourceTest.java | 365 +++++
.../seatunnel/jdbc/catalog/db2/DB2Catalog.java | 2 +-
.../seatunnel/jdbc/internal/JdbcOutputFormat.java | 205 ++-
.../jdbc/internal/JdbcOutputFormatBuilder.java | 15 +-
.../dialect/saphana/SapHanaTypeConverter.java | 3 +
.../BufferReducedBatchStatementExecutor.java | 52 +-
.../executor/BufferedBatchStatementExecutor.java | 26 +-
.../seatunnel/jdbc/internal/xa/XaFacade.java | 7 +-
.../jdbc/internal/xa/XaFacadeImplAutoLoad.java | 14 +-
.../seatunnel/jdbc/internal/xa/XaGroupOps.java | 13 +-
.../seatunnel/jdbc/internal/xa/XaGroupOpsImpl.java | 9 +-
.../jdbc/sink/AbstractJdbcSinkWriter.java | 33 +-
.../connectors/seatunnel/jdbc/sink/JdbcSink.java | 3 +-
.../jdbc/sink/JdbcSinkAggregatedCommitter.java | 278 +++-
.../seatunnel/jdbc/sink/JdbcSinkWriter.java | 144 +-
.../seatunnel/jdbc/source/ChunkSplitter.java | 44 +-
.../jdbc/source/DynamicChunkSplitter.java | 121 +-
.../seatunnel/jdbc/source/JdbcSourceReader.java | 13 +
.../seatunnel/jdbc/source/JdbcSourceTable.java | 22 +
.../seatunnel/jdbc/utils/ObjectUtils.java | 16 +-
.../seatunnel/jdbc/catalog/db2/DB2CatalogTest.java | 35 +
.../internal/JdbcOutputFormatBatchCommitTest.java | 171 +++
.../JdbcOutputFormatReconnectSafetyTest.java | 187 +++
.../jdbc/internal/JdbcOutputFormatTest.java | 30 +-
.../dialect/saphana/SapHanaTypeConverterTest.java | 14 +
.../jdbc/internal/executor/BufferExecutorTest.java | 12 +-
.../jdbc/internal/xa/XaFacadeImplAutoLoadTest.java | 145 ++
.../jdbc/internal/xa/XaGroupOpsImplTest.java | 122 ++
.../jdbc/sink/JdbcSinkAggregatedCommitterTest.java | 440 ++++++
...kWriterSharedPhysicalTableSchemaChangeTest.java | 6 +-
.../seatunnel/jdbc/sink/JdbcSinkWriterTest.java | 330 +++++
.../jdbc/source/DynamicChunkSplitterTest.java | 145 +-
.../seatunnel/kafka/config/KafkaSinkOptions.java | 8 +
.../seatunnel/kafka/config/KafkaSourceOptions.java | 5 +-
.../serialize/DefaultSeaTunnelRowSerializer.java | 45 +-
.../seatunnel/kafka/sink/KafkaSinkWriter.java | 49 +
.../seatunnel/kafka/source/KafkaSourceConfig.java | 17 +-
.../kafka/source/KafkaSourceDryRunValidator.java | 139 ++
.../seatunnel/kafka/source/KafkaSourceFactory.java | 21 +-
.../seatunnel/kafka/KafkaFactoryTest.java | 11 +
.../DefaultSeaTunnelRowSerializerTest.java | 47 +
.../source/KafkaSourceDryRunValidatorTest.java | 512 +++++++
.../seatunnel/lance/sink/LanceSinkFactory.java | 7 +-
.../seatunnel/lance/sink/LanceSinkWriter.java | 16 +-
.../seatunnel/lance/utils/FragmentConverter.java | 42 +-
.../seatunnel/lance/LanceFactoryTest.java | 111 +-
.../seatunnel/lance/sink/LanceSinkTest.java | 24 +
.../lance/utils/FragmentConverterTest.java | 69 +
.../seatunnel/mqtt/source/MqttSourceConfig.java | 10 +-
.../mqtt/source/MqttSourceConfigTest.java | 46 +
.../seatunnel/mqtt/source/MqttSourceTest.java | 40 +
.../openmldb/config/OpenMldbSqlExecutor.java | 71 +-
.../openmldb/source/OpenMldbReadClient.java | 209 +++
.../seatunnel/openmldb/source/OpenMldbSource.java | 45 +-
.../openmldb/source/OpenMldbSourceFactory.java | 127 +-
.../openmldb/source/OpenMldbSourceReader.java | 121 +-
.../seatunnel/openmldb/OpenMldbFactoryTest.java | 205 +++
.../openmldb/source/OpenMldbSourceReaderTest.java | 238 ++++
.../openmldb/source/OpenMldbSourceTest.java | 143 ++
.../openmldb/source/TestOpenMldbSourceIT.java | 386 ++++++
.../seatunnel/paimon/sink/PaimonSink.java | 5 +
.../seatunnel/paimon/sink/PaimonSinkWriter.java | 21 +-
.../paimon/sink/writer/PaimonWriteTest.java | 142 ++
.../seatunnel/prometheus/sink/PrometheusSink.java | 12 +
.../prometheus/sink/PrometheusWriter.java | 183 ++-
.../prometheus/sink/PrometheusWriterTest.java | 158 +++
seatunnel-connectors-v2/connector-rabbitmq/pom.xml | 5 +
.../seatunnel/rabbitmq/client/RabbitmqClient.java | 55 +-
.../rabbitmq/config/RabbitmqBaseOptions.java | 39 +
.../seatunnel/rabbitmq/config/RabbitmqConfig.java | 35 +-
.../rabbitmq/config/RabbitmqMessageFormat.java | 15 +-
.../config/RabbitmqTableConfigsValidator.java | 17 +
.../exception/RabbitmqConnectorErrorCode.java | 3 +-
.../rabbitmq/sink/RabbitmqSinkFactory.java | 11 +
.../rabbitmq/sink/RabbitmqSinkWriter.java | 29 +-
.../seatunnel/rabbitmq/source/RabbitmqSource.java | 27 +-
.../rabbitmq/source/RabbitmqSourceFactory.java | 11 +
.../rabbitmq/source/RabbitmqSourceReader.java | 36 +-
.../seatunnel/rabbitmq/RabbitmqFactoryTest.java | 42 +
.../rabbitmq/RabbitmqSinkFactoryTest.java | 84 ++
.../rabbitmq/RabbitmqSourceFactoryTest.java | 85 ++
.../seatunnel/rabbitmq/RabbitmqSourceTest.java | 59 +
.../rabbitmq/client/RabbitmqClientTest.java | 83 ++
.../seatunnel/redis/config/RedisBaseOptions.java | 11 +-
.../seatunnel/redis/config/RedisParameters.java | 65 +-
.../connectors/seatunnel/redis/Redis7Test.java | 257 ++++
.../seatunnel/redis/RedisFactoryTest.java | 74 +
.../rocketmq/common/RocketMqAdminUtil.java | 132 +-
.../rocketmq/source/RocketMqConsumerThread.java | 8 +
.../rocketmq/source/RocketMqSourceReader.java | 2 +
.../rocketmq/common/RocketMqAdminUtilTest.java | 239 ++++
.../source/RocketMqSourceSplitEnumeratorTest.java | 51 +
.../redshift/sink/S3RedshiftSinkFactory.java | 11 +-
.../redshift/sink/S3RedshiftSinkFactoryTest.java | 80 ++
.../salesforce/client/SalesforceClient.java | 223 ++-
.../salesforce/config/SalesforceSinkConfig.java | 107 ++
.../salesforce/config/SalesforceSinkOptions.java | 53 +
.../exception/SalesforceConnectorErrorCode.java | 3 +-
.../salesforce/sink/SalesforceRowSerializer.java | 206 +++
.../seatunnel/salesforce/sink/SalesforceSink.java} | 34 +-
.../salesforce/sink/SalesforceSinkFactory.java | 91 ++
.../salesforce/sink/SalesforceSinkWriter.java | 174 +++
.../sink/SalesforceRowSerializerTest.java | 251 ++++
.../salesforce/sink/SalesforceSinkTest.java | 505 +++++++
.../seatunnel/sentry/sink/SentrySinkFactory.java | 3 +-
.../seatunnel/sentry/SentryFactoryTest.java | 41 +-
.../seatunnel/slack/client/SlackClient.java | 26 +-
.../seatunnel/slack/sink/SlackSinkFactory.java | 9 +-
.../seatunnel/slack/client/SlackClientTest.java} | 19 +-
.../seatunnel/slack/sink/SlackFactoryTest.java | 96 ++
.../connectors/seatunnel/sls/sink/SlsSink.java | 13 +-
.../seatunnel/sls/sink/SlsSinkFactory.java | 5 +-
.../seatunnel/snmp/client/SnmpTargetFactory.java | 51 +
.../{SnmpSourceOptions.java => SnmpOptions.java} | 19 +-
.../seatunnel/snmp/config/SnmpSinkConfig.java | 131 ++
.../seatunnel/snmp/config/SnmpSinkOptions.java | 53 +
.../seatunnel/snmp/config/SnmpSourceConfig.java | 39 +-
.../seatunnel/snmp/config/SnmpSourceOptions.java | 29 +-
.../seatunnel/snmp/config/SnmpTargetConfig.java} | 21 +-
.../snmp/exception/SnmpConnectorErrorCode.java | 6 +-
.../Snmp4jSetClient.java} | 67 +-
.../seatunnel/snmp/sink/SnmpSetClient.java | 17 +-
.../seatunnel/snmp/sink/SnmpSetRequest.java} | 25 +-
.../connectors/seatunnel/snmp/sink/SnmpSink.java} | 34 +-
.../seatunnel/snmp/sink/SnmpSinkFactory.java | 70 +
.../seatunnel/snmp/sink/SnmpSinkRowConverter.java | 316 +++++
.../seatunnel/snmp/sink/SnmpSinkWriter.java | 93 ++
.../seatunnel/snmp/source/Snmp4jClient.java | 13 +-
.../snmp/client/SnmpTargetFactoryTest.java | 47 +
.../seatunnel/snmp/config/SnmpSinkConfigTest.java | 119 ++
.../snmp/config/SnmpSourceConfigTest.java | 34 +
.../seatunnel/snmp/sink/Snmp4jSetClientTest.java | 160 +++
.../seatunnel/snmp/sink/SnmpSinkFactoryTest.java | 189 +++
.../snmp/sink/SnmpSinkRowConverterTest.java | 246 ++++
.../seatunnel/snmp/sink/SnmpSinkWriterTest.java | 133 ++
.../starrocks/sink/StarRocksSinkWriter.java | 12 +
.../connector-syslog/examples/fake_to_syslog.conf | 50 +
.../connector-syslog}/pom.xml | 16 +-
.../seatunnel/syslog/config/SyslogSinkConfig.java | 65 +
.../seatunnel/syslog/config/SyslogSinkOptions.java | 76 +
.../syslog/sink/SyslogMessageEncoder.java | 241 ++++
.../seatunnel/syslog/sink/SyslogSink.java} | 38 +-
.../seatunnel/syslog/sink/SyslogSinkFactory.java | 73 +
.../seatunnel/syslog/sink/SyslogSinkWriter.java | 86 ++
.../seatunnel/syslog/sink/SyslogTlsClient.java | 304 ++++
.../syslog/sink/SyslogMessageEncoderTest.java | 306 ++++
.../syslog/sink/SyslogSinkFactoryTest.java | 141 ++
.../syslog/sink/SyslogSinkWriterTest.java | 240 ++++
.../seatunnel/syslog/sink/SyslogTlsClientTest.java | 395 ++++++
.../tablestore/sink/TableStoreSinkFactory.java | 17 +-
.../tablestore/source/TableStoreSourceFactory.java | 18 +-
.../tablestore/TableStoreFactoryTest.java | 154 ++-
.../connector-tiktok-ads/pom.xml | 79 ++
.../seatunnel/tiktok/ads/TikTokAdsClient.java | 236 ++++
.../seatunnel/tiktok/ads/TikTokAdsConfig.java | 204 +++
.../seatunnel/tiktok/ads/TikTokAdsReport.java | 213 +++
.../seatunnel/tiktok/ads/TikTokAdsSource.java | 67 +
.../tiktok/ads/TikTokAdsSourceFactory.java} | 45 +-
.../tiktok/ads/TikTokAdsSourceOptions.java | 110 ++
.../tiktok/ads/TikTokAdsSourceReader.java | 150 ++
.../tiktok/ads/TestTikTokAdsPackagingIT.java | 161 +++
.../seatunnel/tiktok/ads/TikTokAdsReportTest.java | 438 ++++++
.../tiktok/ads/TikTokAdsSourceReaderTest.java | 456 ++++++
.../typesense/sink/TypesenseSinkFactory.java | 11 +-
.../typesense/source/TypesenseSourceFactory.java | 8 +-
.../typesense/sink/TypesenseFactoryTest.java | 107 +-
.../seatunnel/source/Web3jSourceFactory.java | 3 +-
.../connectors/seatunnel/Web3jFactoryTest.java | 74 +
seatunnel-connectors-v2/pom.xml | 6 +
.../core/starter/utils/ConfigShadeUtils.java | 2 +-
.../core/starter/utils/ConfigBuilderTest.java | 43 +
.../flink/execution/TransformExecuteProcessor.java | 72 +-
.../execution/TransformExecuteProcessorTest.java | 151 ++
.../spark/execution/TransformExecuteProcessor.java | 56 +-
.../execution/TransformExecuteProcessorTest.java | 156 +++
seatunnel-dist/pom.xml | 66 +
seatunnel-dist/release-docs/LICENSE | 28 +
.../licenses/LICENSE-codec-commons-codec.txt | 404 +++---
.../release-docs/licenses/LICENSE-commons-lang.txt | 404 +++---
.../licenses/LICENSE-google-api-common.txt | 26 +
.../release-docs/licenses/LICENSE-google-auth.txt | 28 +
.../release-docs/licenses/LICENSE-snappy-java.txt | 404 +++---
.../src/main/assembly/assembly-seatunnel-src.xml | 6 +
.../connector/TransformSpecificationCheckTest.java | 2 +-
.../connector-activemq-e2e/pom.xml | 2 +-
.../connector-amazondocumentdb-e2e/pom.xml | 51 +
.../amazondocumentdb/AmazonDocumentDBIT.java | 155 +++
.../resources/amazondocumentdb_source_basic.conf | 65 +
.../amazondocumentdb_source_projection.conf | 60 +
.../amazondocumentdb_source_query_filter.conf | 56 +
.../connector-amazonsqs-e2e/pom.xml | 2 +-
.../connector-bigquery-e2e/pom.xml | 2 +-
.../e2e/connector/bigquery/AbstractBigqueryIT.java | 44 +-
.../e2e/connector/bigquery/BigQueryCDCIT.java | 257 ----
.../e2e/connector/bigquery/BigQueryCDCRealIT.java | 417 ++++++
.../e2e/connector/bigquery/BigqueryIT.java | 65 +-
.../src/test/resources/fake_to_bigquery_sink.conf | 1 +
...k.conf => fake_to_bigquery_streaming_sink.conf} | 49 +-
.../resources/mysql_cdc_to_bigquery_real_sink.conf | 46 +
.../src/test/java/mongodb/MongodbCDCIT.java | 120 ++
.../resources/mongodbcdc_stop_mode_timestamp.conf | 61 +
.../cdc/mysql/AbstractMysqlCDCITBase.java | 3 +-
...mysqlcdc_to_mysql_with_column_include_list.conf | 2 +-
.../pom.xml | 35 +-
.../cdc/oceanbase/MySqlCompatibleContainer.java | 287 ++++
.../cdc/oceanbase/OceanBaseCDCCompatibilityIT.java | 288 ++++
.../src/test/resources/docker/server-gtids/my.cnf | 0
.../src/test/resources/docker/setup.sql | 24 +
.../oceanbasecdc_to_mysql_compatible.conf} | 25 +-
.../seatunnel/cdc/postgres/OpengaussCDCIT.java | 2 +-
.../seatunnel/cdc/postgres/PostgresCDCIT.java | 39 +-
.../postgrescdc_to_postgres_test_add_Filed.conf | 4 +-
.../clickhouse/ClickhouseOffsetTimestampIT.java | 269 ++++
.../e2e/connector/couchbase/CouchbaseIT.java | 110 +-
.../connector/couchbase/CouchbaseReadinessIT.java | 167 +++
.../test/resources/fake_source_to_couchbase.conf | 1 -
...f => fake_source_to_couchbase_timer_flush.conf} | 16 +-
.../connector-databend-e2e/pom.xml | 1 -
.../e2e/connector/databend/DatabendCDCSinkIT.java | 7 +-
.../e2e/connector/databend/DatabendIT.java | 7 +-
.../e2e/connector/doris/DorisErrorIT.java | 15 +-
.../seatunnel/e2e/connector/doris/DorisIT.java | 34 +-
.../connector-elasticsearch-e2e/pom.xml | 2 +-
.../seatunnel/e2e/connector/fake/FakeIT.java | 6 +
.../e2e/connector/fake/FakeSqlConfIT.java | 6 +
...ConfIT.java => SharedContainerTestSupport.java} | 20 +-
.../e2e/connector/file/gcs/GcsFileIT.java | 14 +
.../src/test/resources/gcs/gcs_file_to_gcs.conf | 67 +
.../src/test/resources/gcs/gcs_sink_to_assert.conf | 63 +
.../connector-file-local-e2e/pom.xml | 2 +-
.../connector/file/s3/S3FileConnectDryRunIT.java | 190 +++
.../file/s3/S3FileConnectDryRunWireIT.java | 249 ++++
.../e2e/connector/file/s3/S3FileWithFilterIT.java | 6 +-
.../e2e/connector/firebase/FirebaseSinkIT.java | 196 +++
.../test/resources/fake_source_to_firebase.conf} | 58 +-
.../connector-google-analytics4-e2e/pom.xml | 48 +
.../google/analytics4/GoogleAnalytics4IT.java | 135 ++
.../resources/google_analytics4_to_assert.conf | 55 +
.../connector-http-e2e/pom.xml | 6 +
.../e2e/connector/http/SalesforceSinkIT.java | 132 ++
.../src/test/resources/fake_to_salesforce.conf | 47 +
.../connector-hudi-e2e/pom.xml | 2 +-
.../hudi/HudiSeatunnelS3MultiTableIT.java | 15 +-
.../connector/hudi/HudiSparkS3MultiTableIT.java | 15 +-
.../connector-iceberg-s3-e2e/pom.xml | 1 -
.../e2e/connector/iceberg/s3/IcebergSourceIT.java | 15 +-
.../connector-influxdb-e2e/pom.xml | 6 +
.../influxdb/InfluxDBMultiTableSourceIT.java | 218 +++
.../e2e/connector/influxdb/InfluxdbIT.java | 7 +
.../resources/influxdb-multi-table-source.conf | 87 ++
.../connector-iotdb-e2e/pom.xml | 6 +
.../seatunnel/e2e/connector/iotdb/IoTDBIT.java | 12 +
.../connector/iotdb/IoTDBMultiTableSourceIT.java | 170 +++
.../resources/iotdb/iotdb_multi_table_source.conf | 69 +
.../jdbc/internal/xa/XaGroupOpsImplIT.java | 75 +-
.../connector-jdbc-e2e-part-2/pom.xml | 7 +-
.../seatunnel/jdbc/JdbcOceanBaseMilvusIT.java | 2 +-
.../connectors/seatunnel/jdbc/JdbcHanaIT.java | 5 +-
.../e2e/connector/kafka/KafkaConnectDryRunIT.java | 209 +++
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 2 +-
.../connector-milvus-e2e/pom.xml | 7 +-
.../e2e/connector/nebulagraph/NebulaGraphIT.java | 33 +-
.../connector-paimon-e2e/pom.xml | 2 +-
.../e2e/connector/paimon/PaimonWithS3IT.java | 15 +-
.../connector-paypal-e2e/pom.xml | 54 +
.../seatunnel/e2e/connector/paypal/PayPalIT.java | 155 +++
.../e2e/connector/paypal/PayPalMaskingTest.java | 63 +
.../src/test/resources/paypal_to_assert.conf | 52 +
.../connector-qdrant-e2e/pom.xml | 2 +-
.../e2e/connector/rabbitmq/RabbitmqIT.java | 143 ++
.../resources/rabbitmq-protobuf-to-rabbitmq.conf | 83 ++
.../seatunnel/e2e/connector/redis/Redis7IT.java | 46 +
.../connector/redis/RedisTestCaseTemplateIT.java | 2 +-
.../src/test/resources/redis-named-user.conf | 50 +
.../e2e/connector/rocketmq/RocketMqContainer.java | 123 +-
.../e2e/connector/rocketmq/RocketMqIT.java | 168 ++-
.../rocketmq-source_text_error_tag_to_console.conf | 3 +-
.../rocketmq-source_text_tag_to_console.conf | 3 +-
.../pom.xml | 7 +-
.../seatunnel/e2e/connector/snmp/SnmpAgent.java | 95 ++
.../seatunnel/e2e/connector/snmp/SnmpSinkIT.java | 109 ++
.../src/test/resources/fake_to_snmp.conf} | 42 +-
.../pom.xml | 11 +-
.../e2e/connector/syslog/SyslogSinkIT.java | 232 ++++
.../src/test/resources/docker/syslog-ng.conf | 29 +
.../src/test/resources/fake_to_syslog.conf} | 59 +-
.../connector-tiktok-ads-e2e/pom.xml | 48 +
.../e2e/connector/tiktok/ads/TikTokAdsIT.java | 131 ++
.../src/test/resources/tiktok_ads_to_assert.conf | 60 +
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 7 +
.../src/test/docker/spark/Dockerfile | 3 +
.../src/test/docker/spark/docker-bake.hcl | 8 +-
.../common/container/ReusableTestContainer.java | 39 +
.../flink/AbstractTestFlinkContainer.java | 38 +
.../common/container/flink/Flink20Container.java | 2 +
.../container/seatunnel/SeaTunnelContainer.java | 314 ++++-
.../common/junit/ContainerTestingExtension.java | 89 +-
.../e2e/common/junit/ReuseTestContainers.java | 42 +
.../common/junit/SharedTestContainerResource.java | 100 ++
.../junit/SharedTestContainerResourceTest.java | 267 ++++
.../junit/TestCaseInvocationContextProvider.java | 41 +-
.../e2e/sink/inmemory/InMemorySinkFactory.java | 12 +
.../e2e/sink/inmemory/InMemorySinkWriter.java | 13 +
.../engine/e2e/BackpressureSlowSinkIT.java | 335 +++++
.../e2e/CheckpointCoordinatorFailoverIT.java | 534 +++++++
.../engine/e2e/CheckpointMonitorStartupRaceIT.java | 597 ++++++++
.../engine/e2e/CheckpointRestoreWithStopIT.java | 381 ++++-
.../e2e/ClusterFaultToleranceTwoPipelineIT.java | 189 +++
.../CoordinatorExecutorMassFailoverStormIT.java | 482 +++++++
.../engine/e2e/DynamicSlotNoCapacityCheckIT.java | 234 ++++
.../engine/e2e/SavepointBusySourceBarrierIT.java | 368 +++++
.../seatunnel/engine/e2e/SeaTunnelSlotIT.java | 103 ++
...gregatedCommitterTaskCheckpointCacheLeakIT.java | 267 ++++
.../engine/e2e/SplitClusterFaultToleranceIT.java | 869 ++++++++++++
.../SplitClusterPendingJobLifecycleFailoverIT.java | 610 ++++++++
...plitClusterTerminalZombieJobMasterSwitchIT.java | 608 ++++++++
.../e2e/TaskDeploymentClassLoaderLeakIT.java | 308 +++++
...kDeploymentPrePublicationClassLoaderLeakIT.java | 733 ++++++++++
.../e2e/telemetry/TelemetryStartupDeadlockIT.java | 473 +++++++
.../FinalCheckpointCloseHoldGate.java | 153 ++
.../FinalCheckpointCloseHoldSink.java | 35 +-
.../FinalCheckpointCloseHoldSinkFactory.java | 78 ++
.../FinalCheckpointCloseHoldSinkWriter.java | 123 ++
...ClusterWorkerRestartAfterFinalCheckpointIT.java | 573 ++++++++
.../batch_fake_to_console_minimal_slot.conf} | 36 +-
...ocalfile_close_handshake_failover_template.conf | 78 ++
...sequence_to_localfile_corrupted_checkpoint.conf | 52 +
...ter_batch_fake_to_close_hold_sink_template.conf | 51 +
...fake_to_localfile_slot_contention_template.conf | 132 ++
...h_one_pipeline_permanently_failed_template.conf | 104 ++
.../resources/dynamic_slot_no_capacity_check.conf} | 38 +-
.../pending_jobs_streaming_unschedulable.conf | 42 +
...tream_fake_busy_split_to_console_savepoint.conf | 60 +
..._to_console_terminal_zombie_master_switch.conf} | 44 +-
...eckpoint_trigger_dispatch_failure_template.conf | 71 +
...t_fakesource_to_slow_inmemory_backpressure.conf | 67 +
...ing_fake_to_localfile_committer_cache_leak.conf | 52 +
.../seatunnel/engine/e2e/k8s/KubernetesIT.java | 131 +-
.../e2e/transform/TestPythonTransformIT.java | 410 ++++++
.../python_transform/python_transform.conf | 118 ++
.../python_transform/python_transform_path.conf | 112 ++
.../python_transform/python_transform_path.py | 21 +
.../engine/common/config/EngineConfig.java | 12 +
.../config/YamlSeaTunnelDomConfigProcessor.java | 27 +
.../engine/common/config/server/HttpConfig.java | 8 +
.../common/config/server/ServerConfigOptions.java | 23 +
.../serializer/protobuf/ProtoStuffSerializer.java | 13 +-
.../protobuf/ProtoStuffSerializerTest.java | 56 +
.../engine/server/CoordinatorService.java | 13 +-
.../seatunnel/engine/server/JettyService.java | 13 +-
.../engine/server/SeaTunnelHealthMonitor.java | 18 +-
.../engine/server/TaskExecutionService.java | 371 +++--
.../server/checkpoint/CheckpointCoordinator.java | 63 +-
.../HazelcastMetricsSnapshotStateStore.java | 56 +-
.../engine/server/execution/TaskGroupContext.java | 80 +-
.../seatunnel/engine/server/master/JobMaster.java | 109 +-
.../resourcemanager/AbstractResourceManager.java | 12 +-
.../server/resourcemanager/ResourceManager.java | 5 +-
.../resourcemanager/resource/SlotProfile.java | 21 +-
.../rest/filter/ExceptionHandlingFilter.java | 4 +-
.../engine/server/rest/service/BaseService.java | 105 +-
.../engine/server/rest/service/JobInfoService.java | 85 +-
.../server/rest/service/UpdateTagsService.java | 11 +
.../server/rest/servlet/FinishedJobsServlet.java | 21 +-
.../server/rest/servlet/PageBaseServlet.java | 145 +-
.../server/service/slot/DefaultSlotService.java | 29 +-
.../server/task/SinkAggregatedCommitterTask.java | 2 +-
.../server/task/error/DefaultErrorSinkWriter.java | 49 +-
.../DeleteConnectorJarInExecutionNode.java | 3 +
.../SendConnectorJarToMemberNodeOperation.java | 3 +
.../engine/server/utils/PeekBlockingQueue.java | 10 +-
.../engine/server/ConnectorPackageServiceTest.java | 62 +
.../engine/server/CoordinatorServiceTest.java | 187 ++-
.../engine/server/SeaTunnelHealthMonitorTest.java | 64 +
.../engine/server/TaskExecutionServiceTest.java | 325 ++++-
.../checkpoint/CheckpointCoordinatorTest.java | 239 ++++
.../CheckpointStorageRetentionPruneTest.java | 292 ++++
.../HazelcastMetricsSnapshotStateStoreTest.java | 302 +++-
.../JobMasterMasterFailoverResourceTest.java | 281 ++++
.../resourcemanager/ResourceManagerTest.java | 59 +
.../rest/filter/ExceptionHandlingFilterTest.java | 80 ++
.../rest/service/BaseServiceHealthMetricsTest.java | 158 +++
.../rest/service/JobInfoServiceNullSafetyTest.java | 48 +
.../rest/servlet/FinishedJobsServletTest.java | 179 +++
.../task/SinkAggregatedCommitterTaskTest.java | 20 +
.../task/error/DefaultErrorSinkWriterTest.java | 83 ++
.../task/flow/TransformFlowLifeCycleCloseTest.java | 65 +
.../engine/server/utils/PeekBlockingQueueTest.java | 2 +-
.../src/components/live-metrics-chart/board.tsx | 38 +-
.../src/components/live-metrics-chart/index.tsx | 87 +-
.../seatunnel-engine-ui/src/service/job/index.ts | 4 +-
.../seatunnel-engine-ui/src/tests/jobs.spec.ts | 14 +-
.../seatunnel-engine-ui/src/views/jobs/detail.scss | 156 ++-
.../seatunnel-engine-ui/src/views/jobs/detail.tsx | 143 +-
.../examples/google_analytics4_to_console.conf | 43 +
.../resources/examples/tiktok_ads_to_console.conf | 44 +
.../format/avro/AvroDeserializationSchema.java | 35 +-
.../format/avro/AvroSerializationSchemaTest.java | 46 +
.../seatunnel/format/json/RowToJsonConverters.java | 68 +-
.../format/json/JsonRowDataSerDeSchemaTest.java | 48 +
.../transform/calcite/CalciteTransform.java | 4 +
.../common/AbstractCatalogSupportMapTransform.java | 4 +
.../transform/common/ChainedMapTransform.java | 16 +-
.../filterrowkind/FilterRowKindTransform.java | 12 +-
.../FilterRowKindTransformFactory.java | 9 +-
.../nlpmodel/embedding/EmbeddingTransform.java | 22 +-
.../transform/python/PythonColumnConfig.java | 47 +-
.../python/PythonMultiCatalogTransform.java | 96 ++
.../transform/python/PythonProcessWorker.java | 1456 ++++++++++++++++++++
.../transform/python/PythonTransform.java | 320 +++++
.../transform/python/PythonTransformConfig.java | 241 ++++
.../transform/python/PythonTransformErrorCode.java | 82 ++
.../transform/python/PythonTransformFactory.java | 126 ++
.../transform/rename/FieldRenameTransform.java | 23 +-
.../transform/rename/TableRenameTransform.java | 26 +-
.../seatunnel/transform/sql/SQLTransform.java | 4 +
.../sql/zeta/functions/NumericFunction.java | 6 +
.../sql/zeta/functions/SystemFunction.java | 30 +-
.../resources/python_transform/worker_template.py | 79 ++
.../FilterRowKindTransformFactoryTest.java | 98 +-
.../common/AbstractMultiCatalogTransformTest.java | 59 +
.../embedding/AmazonEmbeddingInvocationTest.java | 314 +++++
.../transform/python/PythonTransformTest.java | 1221 ++++++++++++++++
.../transform/rename/FieldRenameTransformTest.java | 47 +
.../transform/rename/TableRenameTransformTest.java | 53 +
.../transform/sql/SQLNumericFunctionsTest.java | 21 +
.../seatunnel/transform/sql/SQLTransformTest.java | 35 +
.../sql/zeta/functions/SystemFunctionTest.java | 137 ++
.../translation/flink/schema/SchemaOperator.java | 8 +-
.../flink/schema/SchemaOperatorTest.java | 35 +-
985 files changed, 81159 insertions(+), 4843 deletions(-)
create mode 100644 .github/workflows/cli.yml
create mode 100644 docs/en/connector-v2/source/FacebookAds.md
create mode 100644 docs/en/connector-v2/source/GoogleAds.md
create mode 100644 docs/en/connector-v2/source/Http-Linear.md
create mode 100644 docs/en/connectors/changelog/connector-amazondocumentdb.md
copy docs/en/connectors/changelog/{connector-cdc-db2.md =>
connector-cdc-oceanbase.md} (100%)
create mode 100644 docs/en/connectors/changelog/connector-google-analytics4.md
create mode 100644 docs/en/connectors/changelog/connector-http-paypal.md
create mode 100644 docs/en/connectors/changelog/connector-http-splunk.md
copy docs/en/connectors/changelog/{connector-snmp.md => connector-mem0.md}
(56%)
create mode 100644 docs/en/connectors/changelog/connector-salesforce.md
create mode 100644 docs/en/connectors/changelog/connector-syslog.md
create mode 100644 docs/en/connectors/changelog/connector-tiktok-ads.md
create mode 100644 docs/en/connectors/sink/Firebase.md
create mode 100644 docs/en/connectors/sink/GcsFile.md
create mode 100644 docs/en/connectors/sink/Mem0.md
create mode 100644 docs/en/connectors/sink/SNMP.md
create mode 100644 docs/en/connectors/sink/Salesforce.md
create mode 100644 docs/en/connectors/sink/Syslog.md
create mode 100644 docs/en/connectors/sink/Zendesk.md
create mode 100644 docs/en/connectors/source/AmazonDocumentDB.md
create mode 100644 docs/en/connectors/source/GoogleAnalytics4.md
create mode 100644 docs/en/connectors/source/OceanBase-CDC.md
create mode 100644 docs/en/connectors/source/PayPal.md
create mode 100644 docs/en/connectors/source/Splunk.md
create mode 100644 docs/en/connectors/source/TikTokAds.md
create mode 100644 docs/en/developer/anydoc-document-parser-poc.md
create mode 100644 docs/en/developer/contribute-performance-guide.md
create mode 100644 docs/en/getting-started/recipes/mysql-to-hdfs.md
create mode 100644 docs/en/tools/dolphinscheduler-integration.md
create mode 100644 docs/en/transforms/python.md
create mode 100644 docs/zh/connector-v2/source/FacebookAds.md
create mode 100644 docs/zh/connector-v2/source/GoogleAds.md
create mode 100644 docs/zh/connectors/changelog/connector-amazondocumentdb.md
create mode 100644 docs/zh/connectors/changelog/connector-cdc-oceanbase.md
create mode 100644 docs/zh/connectors/changelog/connector-google-analytics4.md
create mode 100644 docs/zh/connectors/changelog/connector-http-paypal.md
copy docs/{en/connectors/changelog/connector-snmp.md =>
zh/connectors/changelog/connector-mem0.md} (56%)
create mode 100644 docs/zh/connectors/changelog/connector-salesforce.md
create mode 100644 docs/zh/connectors/changelog/connector-syslog.md
create mode 100644 docs/zh/connectors/changelog/connector-tiktok-ads.md
create mode 100644 docs/zh/connectors/sink/Firebase.md
create mode 100644 docs/zh/connectors/sink/GcsFile.md
create mode 100644 docs/zh/connectors/sink/Mem0.md
create mode 100644 docs/zh/connectors/sink/SNMP.md
create mode 100644 docs/zh/connectors/sink/Salesforce.md
create mode 100644 docs/zh/connectors/sink/Syslog.md
create mode 100644 docs/zh/connectors/sink/Zendesk.md
create mode 100644 docs/zh/connectors/source/AmazonDocumentDB.md
create mode 100644 docs/zh/connectors/source/GoogleAnalytics4.md
create mode 100644 docs/zh/connectors/source/OceanBase-CDC.md
create mode 100644 docs/zh/connectors/source/PayPal.md
create mode 100644 docs/zh/connectors/source/TikTokAds.md
create mode 100644 docs/zh/developer/anydoc-document-parser-poc.md
create mode 100644 docs/zh/developer/contribute-performance-guide.md
create mode 100644 docs/zh/getting-started/recipes/mysql-to-hdfs.md
create mode 100644 docs/zh/tools/dolphinscheduler-integration.md
create mode 100644 docs/zh/transforms/python.md
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/schema/event/RestoreTableSchemaEvent.java
create mode 100644
seatunnel-api/src/test/java/org/apache/seatunnel/api/table/schema/handler/RestoreTableSchemaEventTest.java
create mode 100644
seatunnel-benchmarks/src/main/java/org/apache/seatunnel/benchmark/ProtoStuffSerializerBenchmark.java
create mode 100644
seatunnel-benchmarks/src/test/java/org/apache/seatunnel/benchmark/ProtoStuffSerializerBenchmarkTest.java
create mode 100644
seatunnel-benchmarks/src/test/java/org/apache/seatunnel/benchmark/storage/imap/IMapDagStorageBenchmarkWorkloadTest.java
create mode 100644
seatunnel-benchmarks/src/test/java/org/apache/seatunnel/benchmark/storage/imap/IMapDagStoragePersistenceTest.java
create mode 100644 seatunnel-cli/benchmark/compare.py
create mode 100644 seatunnel-cli/benchmark/paraphrases.py
create mode 100644 seatunnel-cli/benchmark/tasks/paraphrase.json
create mode 100644 seatunnel-cli/tests/test_benchmark_comparison.py
create mode 100644 seatunnel-cli/tests/test_benchmark_paraphrases.py
copy seatunnel-connectors-v2/{connector-rabbitmq =>
connector-amazondocumentdb}/pom.xml (71%)
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBConfig.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/serialize/DocumentDBItemDeserializer.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSource.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplit.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplitEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceState.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/AmazonDocumentDBSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/DocumentDBItemDeserializerTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBConfigTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplitEnumeratorTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazonsqs/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-bigquery/src/main/java/org/apache/seatunnel/connectors/bigquery/schema/BigQuerySchemaChangeManager.java
create mode 100644
seatunnel-connectors-v2/connector-bigquery/src/main/java/org/apache/seatunnel/connectors/bigquery/schema/BigQueryTypeConverter.java
create mode 100644
seatunnel-connectors-v2/connector-bigquery/src/test/java/org/apache/seatunnel/connectors/bigquery/schema/BigQuerySchemaChangeManagerTest.java
create mode 100644
seatunnel-connectors-v2/connector-bigquery/src/test/java/org/apache/seatunnel/connectors/bigquery/schema/BigQueryTypeConverterTest.java
create mode 100644
seatunnel-connectors-v2/connector-bigquery/src/test/java/org/apache/seatunnel/connectors/bigquery/sink/BigQuerySinkSchemaEvolutionTest.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/test/java/org/apache/seatunnel/connectors/cdc/base/source/reader/IncrementalSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/test/java/org/apache/seatunnel/connectors/cdc/base/source/split/IncrementalSplitTest.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/test/java/org/apache/seatunnel/connectors/cdc/debezium/AbstractDebeziumDeserializationSchemaTest.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/test/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializeSchemaRestoreTest.java
copy
seatunnel-connectors-v2/{connector-datahub/src/test/java/org/apache/seatunnel/connectors/seatunnel/datahub/DataHubFactoryTest.java
=>
connector-cdc/connector-cdc-mongodb/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbStreamFetchTaskTest.java}
(55%)
copy {seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e =>
seatunnel-connectors-v2/connector-cdc/connector-cdc-oceanbase}/pom.xml (80%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oceanbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oceanbase/source/OceanBaseIncrementalSource.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oceanbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oceanbase/source/OceanBaseIncrementalSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oceanbase/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oceanbase/source/OceanBaseIncrementalSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/RelationAwarePostgresSchema.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresRelationSchemaChangeResolver.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresRelationSchemaRecord.java
copy
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/{offset/LsnOffsetTest.java
=> PostgresIncrementalSourceSchemaEvolutionTest.java} (50%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresRelationSchemaChangeResolverTest.java
create mode 100644
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/OffsetDateTimeInjectFunction.java
create mode 100644
seatunnel-connectors-v2/connector-clickhouse/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcRowConverterTest.java
create mode 100644
seatunnel-connectors-v2/connector-couchbase/src/test/java/org/apache/seatunnel/connectors/seatunnel/couchbase/sink/CouchbaseSinkFactoryTest.java
delete mode 100644
seatunnel-connectors-v2/connector-couchbase/src/test/java/org/apache/seatunnel/connectors/seatunnel/couchbase/sink/CouchbaseWriterCloseTest.java
create mode 100644
seatunnel-connectors-v2/connector-couchbase/src/test/java/org/apache/seatunnel/connectors/seatunnel/couchbase/sink/CouchbaseWriterOptionsTest.java
create mode 100644
seatunnel-connectors-v2/connector-couchbase/src/test/java/org/apache/seatunnel/connectors/seatunnel/couchbase/sink/CouchbaseWriterTest.java
create mode 100644 seatunnel-connectors-v2/connector-facebook-ads/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/client/FacebookAdsClient.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/config/FacebookAdsParameters.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/config/FacebookAdsSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/config/FacebookAdsTableConfig.java
copy
seatunnel-connectors-v2/{connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/exception/SnmpConnectorErrorCode.java
=>
connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/exception/FacebookAdsConnectorErrorCode.java}
(63%)
copy
seatunnel-connectors-v2/{connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/exception/SnmpConnectorErrorCode.java
=>
connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/exception/FacebookAdsConnectorException.java}
(55%)
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/source/FacebookAdsSource.java
copy
seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceFactory.java
=>
connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/source/FacebookAdsSourceFactory.java}
(60%)
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/source/FacebookAdsSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/FacebookAdsSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/client/FacebookAdsClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-facebook-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/facebook/ads/source/FacebookAdsSourceTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/LocalFileIdentity.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/state/FileTailState.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/hadoop/ChunkedInputHadoopFileSystemProxy.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/source/LocalFileIdentityTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSerializationCompatibilityTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/anydoc/test_read_excel.md
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/catalog/GcsFileCatalog.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/catalog/GcsFileCatalogFactory.java
copy seatunnel-engine/seatunnel-engine-ui/src/views/jobs/detail.scss =>
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/config/GcsFileSinkOptions.java
(85%)
copy
seatunnel-connectors-v2/{connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/sink/GcsFileSink.java}
(53%)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/sink/GcsFileSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/GcsFileSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/catalog/GcsFileCatalogTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3SourceDryRunValidator.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-s3/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3SourceDryRunValidatorTest.java
copy
seatunnel-connectors-v2/connector-firebase/src/main/java/org/apache/seatunnel/connectors/seatunnel/firebase/config/{FirebaseSourceOptions.java
=> FirebaseBaseOptions.java} (84%)
create mode 100644
seatunnel-connectors-v2/connector-firebase/src/main/java/org/apache/seatunnel/connectors/seatunnel/firebase/config/FirebaseSinkOptions.java
copy
seatunnel-connectors-v2/{connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
connector-firebase/src/main/java/org/apache/seatunnel/connectors/seatunnel/firebase/sink/FirebaseSink.java}
(67%)
copy
seatunnel-connectors-v2/{connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/sink/FlussSinkFactory.java
=>
connector-firebase/src/main/java/org/apache/seatunnel/connectors/seatunnel/firebase/sink/FirebaseSinkFactory.java}
(58%)
create mode 100644
seatunnel-connectors-v2/connector-firebase/src/main/java/org/apache/seatunnel/connectors/seatunnel/firebase/sink/FirebaseSinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-firebase/src/test/java/org/apache/seatunnel/connectors/seatunnel/firebase/sink/FirebaseSinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-fluss/src/test/java/org/apache/seatunnel/connectors/seatunnel/fluss/sink/FlussSinkFactoryTest.java
create mode 100644 seatunnel-connectors-v2/connector-google-ads/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/client/GoogleAdsClient.java
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/config/GoogleAdsParameters.java
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/config/GoogleAdsSourceOptions.java
copy
seatunnel-connectors-v2/{connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceTable.java
=>
connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/config/GoogleAdsTableConfig.java}
(52%)
copy
seatunnel-connectors-v2/{connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/exception/SnmpConnectorErrorCode.java
=>
connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/exception/GoogleAdsConnectorErrorCode.java}
(62%)
copy
seatunnel-connectors-v2/{connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/exception/SnmpConnectorErrorCode.java
=>
connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/exception/GoogleAdsConnectorException.java}
(56%)
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/source/GoogleAdsSource.java
copy
seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceFactory.java
=>
connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/source/GoogleAdsSourceFactory.java}
(55%)
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/ads/source/GoogleAdsSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/ads/GoogleAdsSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/ads/client/GoogleAdsClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-google-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/ads/source/GoogleAdsSourceTest.java
create mode 100644 seatunnel-connectors-v2/connector-google-analytics4/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4Config.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4HttpTransport.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4Report.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4Source.java
copy
seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceFactory.java
=>
connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceFactory.java}
(58%)
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4ReportTest.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/TestGoogleAnalytics4PackagingIT.java
copy {seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e =>
seatunnel-connectors-v2/connector-http/connector-http-linear}/pom.xml (73%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-linear/src/main/java/org/apache/seatunnel/connectors/seatunnel/linear/LinearSource.java
copy
seatunnel-connectors-v2/{connector-web3j/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/Web3jSourceFactory.java
=>
connector-http/connector-http-linear/src/main/java/org/apache/seatunnel/connectors/seatunnel/linear/LinearSourceFactory.java}
(73%)
copy
seatunnel-connectors-v2/{connector-google-firestore/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/firestore/FirestoreFactoryTest.java
=>
connector-http/connector-http-linear/src/main/java/org/apache/seatunnel/connectors/seatunnel/linear/config/LinearSourceOptions.java}
(63%)
copy
seatunnel-connectors-v2/{connector-tablestore/src/test/java/org/apache/seatunnel/connectors/seatunnel/tablestore/TableStoreFactoryTest.java
=>
connector-http/connector-http-linear/src/main/java/org/apache/seatunnel/connectors/seatunnel/linear/config/LinearSourceParameter.java}
(50%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-linear/src/test/java/org/apache/seatunnel/connectors/seatunnel/linear/LinearSourceFactoryTest.java
copy {seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e =>
seatunnel-connectors-v2/connector-http/connector-http-paypal}/pom.xml (73%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalClient.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalConfig.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalResponse.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalSource.java
copy
seatunnel-connectors-v2/{connector-tablestore/src/main/java/org/apache/seatunnel/connectors/seatunnel/tablestore/source/TableStoreSourceFactory.java
=>
connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalSourceFactory.java}
(62%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/main/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/test/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/test/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/PayPalResponseTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-paypal/src/test/java/org/apache/seatunnel/connectors/seatunnel/paypal/source/TestPayPalPackagingIT.java
copy {seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e =>
seatunnel-connectors-v2/connector-http/connector-http-splunk}/pom.xml (77%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/main/java/org/apache/seatunnel/connectors/seatunnel/splunk/SplunkSource.java
copy
seatunnel-connectors-v2/{connector-web3j/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/Web3jSourceFactory.java
=>
connector-http/connector-http-splunk/src/main/java/org/apache/seatunnel/connectors/seatunnel/splunk/SplunkSourceFactory.java}
(70%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/main/java/org/apache/seatunnel/connectors/seatunnel/splunk/SplunkSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/main/java/org/apache/seatunnel/connectors/seatunnel/splunk/config/SplunkSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/main/java/org/apache/seatunnel/connectors/seatunnel/splunk/config/SplunkSourceParameter.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/test/java/org/apache/seatunnel/connectors/seatunnel/splunk/SplunkSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-splunk/src/test/java/org/apache/seatunnel/connectors/seatunnel/splunk/SplunkSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-zendesk/src/main/java/org/apache/seatunnel/connectors/seatunnel/zendesk/config/ZendeskConfig.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-zendesk/src/main/java/org/apache/seatunnel/connectors/seatunnel/zendesk/sink/ZendeskSink.java
copy
seatunnel-connectors-v2/{connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentrySinkFactory.java
=>
connector-http/connector-http-zendesk/src/main/java/org/apache/seatunnel/connectors/seatunnel/zendesk/sink/ZendeskSinkFactory.java}
(62%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-zendesk/src/main/java/org/apache/seatunnel/connectors/seatunnel/zendesk/sink/ZendeskSinkWriter.java
copy
seatunnel-connectors-v2/connector-http/connector-http-zendesk/src/main/java/org/apache/seatunnel/connectors/seatunnel/zendesk/{source/config/ZendeskSourceOptions.java
=> sink/config/ZendeskSinkOptions.java} (53%)
copy
seatunnel-connectors-v2/{connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/SlackFactoryTest.java
=>
connector-http/connector-http-zendesk/src/test/java/org/apache/seatunnel/connectors/seatunnel/zendesk/sink/ZendeskSinkFactoryTest.java}
(75%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-zendesk/src/test/java/org/apache/seatunnel/connectors/seatunnel/zendesk/sink/ZendeskSinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-mem0/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-http/connector-mem0/src/main/java/org/apache/seatunnel/connectors/seatunnel/mem0/config/Mem0SinkOptions.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-mem0/src/main/java/org/apache/seatunnel/connectors/seatunnel/mem0/sink/Mem0Sink.java
copy
seatunnel-connectors-v2/{connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentrySinkFactory.java
=>
connector-http/connector-mem0/src/main/java/org/apache/seatunnel/connectors/seatunnel/mem0/sink/Mem0SinkFactory.java}
(62%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-mem0/src/main/java/org/apache/seatunnel/connectors/seatunnel/mem0/sink/Mem0SinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-mem0/src/test/java/org/apache/seatunnel/connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergTimestampDeleteTest.java
copy
seatunnel-connectors-v2/{connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceTable.java
=>
connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSourceTable.java}
(64%)
create mode 100644
seatunnel-connectors-v2/connector-influxdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBMultiTableSourceTest.java
create mode 100644
seatunnel-connectors-v2/connector-iotdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBMultiTableSourceTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBatchCommitTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatReconnectSafetyTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaFacadeImplAutoLoadTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOpsImplTest.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitterTest.java
create mode 100644
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceDryRunValidator.java
create mode 100644
seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceDryRunValidatorTest.java
create mode 100644
seatunnel-connectors-v2/connector-lance/src/test/java/org/apache/seatunnel/connectors/seatunnel/lance/utils/FragmentConverterTest.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbReadClient.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/test/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/test/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSourceTest.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/test/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/TestOpenMldbSourceIT.java
copy seatunnel-engine/seatunnel-engine-ui/src/views/jobs/detail.scss =>
seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/config/RabbitmqMessageFormat.java
(80%)
create mode 100644
seatunnel-connectors-v2/connector-rabbitmq/src/test/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/RabbitmqSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-rabbitmq/src/test/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/client/RabbitmqClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-rocketmq/src/test/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/RocketMqAdminUtilTest.java
create mode 100644
seatunnel-connectors-v2/connector-s3-redshift/src/test/java/org/apache/seatunnel/connectors/seatunnel/redshift/sink/S3RedshiftSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/config/SalesforceSinkConfig.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/config/SalesforceSinkOptions.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceRowSerializer.java
copy
seatunnel-connectors-v2/{connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceSink.java}
(59%)
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/main/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceSinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/test/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceRowSerializerTest.java
create mode 100644
seatunnel-connectors-v2/connector-salesforce/src/test/java/org/apache/seatunnel/connectors/seatunnel/salesforce/sink/SalesforceSinkTest.java
copy
seatunnel-connectors-v2/{connector-typesense/src/test/java/org/apache/seatunnel/connectors/seatunnel/typesense/sink/TypesenseFactoryTest.java
=>
connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/client/SlackClientTest.java}
(60%)
create mode 100644
seatunnel-connectors-v2/connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/sink/SlackFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/client/SnmpTargetFactory.java
copy
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/{SnmpSourceOptions.java
=> SnmpOptions.java} (78%)
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/SnmpSinkConfig.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/SnmpSinkOptions.java
rename
seatunnel-connectors-v2/{connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/SlackFactoryTest.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/SnmpTargetConfig.java}
(69%)
copy
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/{source/Snmp4jClient.java
=> sink/Snmp4jSetClient.java} (53%)
copy seatunnel-engine/seatunnel-engine-ui/src/views/jobs/detail.scss =>
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSetClient.java
(78%)
copy
seatunnel-connectors-v2/{connector-dingtalk/src/test/java/org/apache/seatunnel/connectors/seatunnel/DingTalkFactoryTest.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSetRequest.java}
(66%)
copy
seatunnel-connectors-v2/{connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSink.java}
(56%)
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkRowConverter.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/client/SnmpTargetFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/SnmpSinkConfigTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/Snmp4jSetClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkRowConverterTest.java
create mode 100644
seatunnel-connectors-v2/connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/examples/fake_to_syslog.conf
copy {seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e =>
seatunnel-connectors-v2/connector-syslog}/pom.xml (73%)
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/config/SyslogSinkConfig.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/config/SyslogSinkOptions.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogMessageEncoder.java
copy
seatunnel-connectors-v2/{connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogSink.java}
(52%)
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogSinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/main/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogTlsClient.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/test/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogMessageEncoderTest.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/test/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogSinkFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/test/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogSinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-syslog/src/test/java/org/apache/seatunnel/connectors/seatunnel/syslog/sink/SyslogTlsClientTest.java
create mode 100644 seatunnel-connectors-v2/connector-tiktok-ads/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsClient.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsConfig.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsReport.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsSource.java
copy
seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceFactory.java
=>
connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsSourceFactory.java}
(59%)
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/main/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TestTikTokAdsPackagingIT.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsReportTest.java
create mode 100644
seatunnel-connectors-v2/connector-tiktok-ads/src/test/java/org/apache/seatunnel/connectors/seatunnel/tiktok/ads/TikTokAdsSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-web3j/src/test/java/org/apache/seatunnel/connectors/seatunnel/Web3jFactoryTest.java
create mode 100644
seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/test/java/org/apache/seatunnel/core/starter/flink/execution/TransformExecuteProcessorTest.java
create mode 100644
seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/test/java/org/apache/seatunnel/core/starter/spark/execution/TransformExecuteProcessorTest.java
create mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-google-api-common.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-google-auth.txt
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/pom.xml
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondocumentdb/AmazonDocumentDBIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_basic.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_projection.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_query_filter.conf
delete mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-bigquery-e2e/src/test/java/org/apache/seatunnel/e2e/connector/bigquery/BigQueryCDCIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-bigquery-e2e/src/test/java/org/apache/seatunnel/e2e/connector/bigquery/BigQueryCDCRealIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-bigquery-e2e/src/test/resources/{fake_to_bigquery_sink.conf
=> fake_to_bigquery_streaming_sink.conf} (57%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-bigquery-e2e/src/test/resources/mysql_cdc_to_bigquery_real_sink.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mongodb-e2e/src/test/resources/mongodbcdc_stop_mode_timestamp.conf
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-amazonsqs-e2e =>
connector-cdc-oceanbase-e2e}/pom.xml (73%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oceanbase-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oceanbase/MySqlCompatibleContainer.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oceanbase-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oceanbase/OceanBaseCDCCompatibilityIT.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-clickhouse-e2e =>
connector-cdc-oceanbase-e2e}/src/test/resources/docker/server-gtids/my.cnf
(100%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oceanbase-e2e/src/test/resources/docker/setup.sql
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-cdc-mysql-e2e/src/test/resources/mysqlcdc_to_mysql_with_column_include_list.conf
=>
connector-cdc-oceanbase-e2e/src/test/resources/oceanbasecdc_to_mysql_compatible.conf}
(52%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseOffsetTimestampIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-couchbase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/couchbase/CouchbaseReadinessIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-couchbase-e2e/src/test/resources/{fake_source_to_couchbase.conf
=> fake_source_to_couchbase_timer_flush.conf} (79%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/{FakeSqlConfIT.java
=> SharedContainerTestSupport.java} (65%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-gcs-e2e/src/test/resources/gcs/gcs_file_to_gcs.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-gcs-e2e/src/test/resources/gcs/gcs_sink_to_assert.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-s3-e2e/src/test/java/org/apache/seatunnel/e2e/connector/file/s3/S3FileConnectDryRunIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-s3-e2e/src/test/java/org/apache/seatunnel/e2e/connector/file/s3/S3FileConnectDryRunWireIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-firebase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/firebase/FirebaseSinkIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=> connector-firebase-e2e/src/test/resources/fake_source_to_firebase.conf}
(51%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-google-analytics4-e2e/pom.xml
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-google-analytics4-e2e/src/test/java/org/apache/seatunnel/e2e/connector/google/analytics4/GoogleAnalytics4IT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-google-analytics4-e2e/src/test/resources/google_analytics4_to_assert.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/SalesforceSinkIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/fake_to_salesforce.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-influxdb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/influxdb/InfluxDBMultiTableSourceIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-influxdb-e2e/src/test/resources/influxdb-multi-table-source.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/iotdb/IoTDBMultiTableSourceIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-iotdb-e2e/src/test/resources/iotdb/iotdb_multi_table_source.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaConnectDryRunIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paypal-e2e/pom.xml
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paypal-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paypal/PayPalIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paypal-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paypal/PayPalMaskingTest.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paypal-e2e/src/test/resources/paypal_to_assert.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rabbitmq-e2e/src/test/resources/rabbitmq-protobuf-to-rabbitmq.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/redis-named-user.conf
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-iotdb-e2e =>
connector-snmp-e2e}/pom.xml (89%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-snmp-e2e/src/test/java/org/apache/seatunnel/e2e/connector/snmp/SnmpAgent.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-snmp-e2e/src/test/java/org/apache/seatunnel/e2e/connector/snmp/SnmpSinkIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=> connector-snmp-e2e/src/test/resources/fake_to_snmp.conf} (50%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-iotdb-e2e =>
connector-syslog-e2e}/pom.xml (89%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-syslog-e2e/src/test/java/org/apache/seatunnel/e2e/connector/syslog/SyslogSinkIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-syslog-e2e/src/test/resources/docker/syslog-ng.conf
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=> connector-syslog-e2e/src/test/resources/fake_to_syslog.conf} (50%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-tiktok-ads-e2e/pom.xml
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-tiktok-ads-e2e/src/test/java/org/apache/seatunnel/e2e/connector/tiktok/ads/TikTokAdsIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-tiktok-ads-e2e/src/test/resources/tiktok_ads_to_assert.conf
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/ReusableTestContainer.java
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/ReuseTestContainers.java
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/SharedTestContainerResource.java
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/SharedTestContainerResourceTest.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/BackpressureSlowSinkIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/CheckpointMonitorStartupRaceIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/CoordinatorExecutorMassFailoverStormIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/DynamicSlotNoCapacityCheckIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SavepointBusySourceBarrierIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkAggregatedCommitterTaskCheckpointCacheLeakIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SplitClusterTerminalZombieJobMasterSwitchIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TaskDeploymentClassLoaderLeakIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TaskDeploymentPrePublicationClassLoaderLeakIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/telemetry/TelemetryStartupDeadlockIT.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldGate.java
copy
seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSink.java
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSink.java
(50%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSinkFactory.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSinkWriter.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/SplitClusterWorkerRestartAfterFinalCheckpointIT.java
copy
seatunnel-e2e/{seatunnel-connector-v2-e2e/connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=>
seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_fake_to_console_minimal_slot.conf}
(50%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_fake_to_localfile_close_handshake_failover_template.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/checkpoint-restore-with-stop/stream_checkpointable_sequence_to_localfile_corrupted_checkpoint.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/cluster_batch_fake_to_close_hold_sink_template.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/cluster_batch_fake_to_localfile_slot_contention_template.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/cluster_batch_one_pipeline_permanently_failed_template.conf
copy
seatunnel-e2e/{seatunnel-connector-v2-e2e/connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=>
seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/dynamic_slot_no_capacity_check.conf}
(50%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/pending_jobs_streaming_unschedulable.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fake_busy_split_to_console_savepoint.conf
copy
seatunnel-e2e/{seatunnel-connector-v2-e2e/connector-couchbase-e2e/src/test/resources/fake_source_to_couchbase.conf
=>
seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fake_to_console_terminal_zombie_master_switch.conf}
(51%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fake_to_localfile_checkpoint_trigger_dispatch_failure_template.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fast_fakesource_to_slow_inmemory_backpressure.conf
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/streaming_fake_to_localfile_committer_cache_leak.conf
create mode 100644
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestPythonTransformIT.java
create mode 100644
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/python_transform/python_transform.conf
create mode 100644
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/python_transform/python_transform_path.conf
create mode 100644
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/python_transform/python_transform_path.py
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitorTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointStorageRetentionPruneTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobMasterMasterFailoverResourceTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/filter/ExceptionHandlingFilterTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/service/BaseServiceHealthMetricsTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/servlet/FinishedJobsServletTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/task/flow/TransformFlowLifeCycleCloseTest.java
create mode 100644
seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/google_analytics4_to_console.conf
create mode 100644
seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/tiktok_ads_to_console.conf
copy
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplit.java
=>
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonColumnConfig.java
(50%)
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonMultiCatalogTransform.java
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonProcessWorker.java
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransform.java
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransformConfig.java
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransformErrorCode.java
create mode 100644
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransformFactory.java
create mode 100644
seatunnel-transforms-v2/src/main/resources/python_transform/worker_template.py
create mode 100644
seatunnel-transforms-v2/src/test/java/org/apache/seatunnel/transform/embedding/AmazonEmbeddingInvocationTest.java
create mode 100644
seatunnel-transforms-v2/src/test/java/org/apache/seatunnel/transform/python/PythonTransformTest.java
