This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch stabilize-doris-e2e-startup-and-visibility
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 6773d141f6 [Test][E2E] Give the Doris e2e container a startup budget
and wait for 2pc sink visibility
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 5cc80c114a Merge remote-tracking branch 'upstream/dev' into fix12142
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 4 +
.github/workflows/benchmarks.yml | 1 +
.github/workflows/labeler/label-scope-conf.yml | 7 +
docs/en/ai-cli/benchmark.md | 31 +
docs/en/connectors/changelog/connector-snmp.md | 1 +
docs/en/connectors/sink/Activemq.md | 25 +
docs/en/connectors/sink/Aerospike.md | 42 ++
docs/en/connectors/sink/Datahub.md | 15 +
docs/en/connectors/sink/Email.md | 20 +
docs/en/connectors/sink/GcsFile.md | 172 +++++
docs/en/connectors/sink/Greenplum.md | 8 +-
docs/en/connectors/sink/InfluxDB.md | 37 ++
docs/en/connectors/sink/Jdbc.md | 10 +
docs/en/connectors/sink/Milvus.md | 16 +
docs/en/connectors/sink/Rabbitmq.md | 16 +
docs/en/connectors/sink/S3File.md | 103 +++
docs/en/connectors/sink/SNMP.md | 137 ++++
docs/en/connectors/sink/Socket.md | 15 +
docs/en/connectors/source/Greenplum.md | 14 +-
docs/en/connectors/source/InfluxDB.md | 66 ++
docs/en/connectors/source/Maxcompute.md | 2 +-
docs/en/connectors/source/Milvus.md | 20 +
docs/en/connectors/source/Mqtt.md | 34 +-
docs/en/connectors/source/OpenMldb.md | 2 +
docs/en/connectors/source/PostgreSQL-CDC.md | 26 +
docs/en/connectors/source/Rabbitmq.md | 21 +
docs/en/connectors/source/S3File.md | 99 +++
docs/en/connectors/source/Socket.md | 15 +
docs/en/connectors/source/Web3j.md | 17 +
docs/en/developer/contribute-performance-guide.md | 96 +++
docs/en/developer/contribution-path.md | 15 +
docs/en/engines/zeta/benchmark.md | 565 ++++++----------
docs/en/engines/zeta/checkpoint-storage.md | 2 +
.../introduction/concepts/incompatible-changes.md | 6 +
docs/sidebars.js | 1 +
docs/zh/ai-cli/benchmark.md | 28 +
docs/zh/connectors/changelog/connector-snmp.md | 1 +
docs/zh/connectors/sink/Activemq.md | 19 +
docs/zh/connectors/sink/Datahub.md | 15 +
docs/zh/connectors/sink/Email.md | 20 +
docs/zh/connectors/sink/GcsFile.md | 165 +++++
docs/zh/connectors/sink/Jdbc.md | 8 +
docs/zh/connectors/sink/Milvus.md | 16 +
docs/zh/connectors/sink/Rabbitmq.md | 16 +
docs/zh/connectors/sink/S3File.md | 103 +++
docs/zh/connectors/sink/SNMP.md | 135 ++++
docs/zh/connectors/sink/Socket.md | 15 +
docs/zh/connectors/source/Greenplum.md | 8 +-
docs/zh/connectors/source/Kafka.md | 2 -
docs/zh/connectors/source/Maxcompute.md | 2 +-
docs/zh/connectors/source/Milvus.md | 20 +
docs/zh/connectors/source/OpenMldb.md | 2 +
docs/zh/connectors/source/PostgreSQL-CDC.md | 24 +
docs/zh/connectors/source/Rabbitmq.md | 20 +
docs/zh/connectors/source/S3File.md | 99 +++
docs/zh/connectors/source/Socket.md | 15 +
docs/zh/connectors/source/Web3j.md | 17 +
docs/zh/developer/contribute-performance-guide.md | 87 +++
docs/zh/developer/contribution-path.md | 15 +
docs/zh/engines/zeta/benchmark.md | 519 ++++++---------
docs/zh/engines/zeta/checkpoint-storage.md | 2 +
.../introduction/concepts/incompatible-changes.md | 6 +
plugin-mapping.properties | 2 +
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 | 54 ++
seatunnel-cli/benchmark/compare.py | 368 +++++++++++
seatunnel-cli/benchmark/runner.py | 10 +
seatunnel-cli/tests/test_benchmark_comparison.py | 539 +++++++++++++++
.../amazonsqs/sink/AmazonSqsSinkFactory.java | 4 +-
.../amazonsqs/source/AmazonSqsSourceFactory.java | 5 +-
.../amazonsqs/AmazonSqsSourceFactoryTest.java | 95 ++-
.../amazonsqs/sink/AmazonSqsSinkFactoryTest.java | 100 +++
.../cdc/base/schema/SchemaChangeResolver.java | 10 +
.../cdc/base/utils/SourceRecordUtils.java | 5 +-
.../row/SeaTunnelRowDebeziumDeserializeSchema.java | 6 +
.../connector/postgresql/PostgresObjectUtils.java | 6 +-
.../postgresql/RelationAwarePostgresSchema.java | 96 +++
.../config/PostgresSourceConfigFactory.java | 6 +-
.../cdc/postgres/source/PostgresDialect.java | 9 +-
.../postgres/source/PostgresIncrementalSource.java | 28 +-
.../source/PostgresIncrementalSourceFactory.java | 23 +-
.../PostgresRelationSchemaChangeResolver.java | 206 ++++++
.../source/PostgresRelationSchemaRecord.java | 74 +++
.../reader/PostgresSourceFetchTaskContext.java | 76 ++-
.../cdc/postgres/utils/PostgresTypeUtils.java | 20 +-
.../PostgresRelationSchemaChangeResolverTest.java | 226 +++++++
.../seatunnel/datahub/sink/DataHubSinkFactory.java | 7 +-
.../seatunnel/datahub/DataHubFactoryTest.java | 72 +-
.../seatunnel/sink/DingTalkSinkFactory.java | 6 +-
.../connectors/seatunnel/DingTalkFactoryTest.java | 50 +-
.../file/hadoop/HadoopFileSystemProxy.java | 11 +
.../file/source/reader/AbstractReadStrategy.java | 20 +-
...uousMultipleTableFileSourceSplitEnumerator.java | 20 +-
.../hadoop/ChunkedInputHadoopFileSystemProxy.java | 120 ++++
.../file/hadoop/HadoopFileSystemProxyTest.java | 50 ++
.../file/source/reader/UpdateSyncModeTest.java | 79 +++
...MultipleTableFileSourceSplitEnumeratorTest.java | 51 ++
.../file/gcs/catalog/GcsFileCatalog.java} | 21 +-
.../file/gcs/catalog/GcsFileCatalogFactory.java} | 23 +-
...eSourceOptions.java => GcsFileSinkOptions.java} | 2 +-
.../seatunnel/file/gcs/sink/GcsFileSink.java} | 20 +-
.../file/gcs/sink/GcsFileSinkFactory.java} | 43 +-
.../seatunnel/file/gcs/GcsFileSinkFactoryTest.java | 188 ++++++
.../file/gcs/catalog/GcsFileCatalogTest.java | 106 +++
.../seatunnel/jdbc/catalog/db2/DB2Catalog.java | 2 +-
.../dialect/saphana/SapHanaTypeConverter.java | 3 +
.../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/JdbcSinkAggregatedCommitter.java | 278 +++++++-
.../jdbc/source/DynamicChunkSplitter.java | 114 ++++
.../seatunnel/jdbc/utils/ObjectUtils.java | 16 +-
.../seatunnel/jdbc/catalog/db2/DB2CatalogTest.java | 35 +
.../dialect/saphana/SapHanaTypeConverterTest.java | 14 +
.../jdbc/internal/xa/XaFacadeImplAutoLoadTest.java | 145 ++++
.../jdbc/internal/xa/XaGroupOpsImplTest.java | 122 ++++
.../jdbc/sink/JdbcSinkAggregatedCommitterTest.java | 440 +++++++++++++
.../jdbc/source/DynamicChunkSplitterTest.java | 60 +-
.../openmldb/source/OpenMldbSourceFactory.java | 4 +-
.../seatunnel/openmldb/OpenMldbFactoryTest.java | 72 ++
.../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/SlackFactoryTest.java | 31 -
.../seatunnel/slack/client/SlackClientTest.java} | 19 +-
.../seatunnel/slack/sink/SlackFactoryTest.java | 96 +++
.../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} | 17 +-
.../snmp/exception/SnmpConnectorErrorCode.java | 6 +-
.../Snmp4jSetClient.java} | 67 +-
.../SnmpClient.java => sink/SnmpSetClient.java} | 9 +-
.../seatunnel/snmp/sink/SnmpSetRequest.java} | 23 +-
.../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} | 32 +-
.../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 ++++
.../typesense/sink/TypesenseSinkFactory.java | 11 +-
.../typesense/source/TypesenseSourceFactory.java | 8 +-
.../typesense/sink/TypesenseFactoryTest.java | 107 ++-
.../seatunnel/source/Web3jSourceFactory.java | 3 +-
.../connectors/seatunnel/Web3jFactoryTest.java | 51 +-
.../core/starter/utils/ConfigShadeUtils.java | 2 +-
.../core/starter/utils/ConfigBuilderTest.java | 19 +
.../seatunnel/cdc/postgres/PostgresCDCIT.java | 39 +-
.../postgrescdc_to_postgres_test_add_Filed.conf | 4 +-
.../seatunnel/e2e/connector/doris/DorisIT.java | 39 +-
.../e2e/connector/file/gcs/GcsFileIT.java | 14 +
...cs_file_to_assert.conf => gcs_file_to_gcs.conf} | 53 +-
...file_to_assert.conf => gcs_sink_to_assert.conf} | 39 +-
.../jdbc/internal/xa/XaGroupOpsImplIT.java | 75 ++-
.../pom.xml | 7 +-
.../seatunnel/e2e/connector/snmp/SnmpAgent.java | 95 +++
.../seatunnel/e2e/connector/snmp/SnmpSinkIT.java | 109 +++
.../src/test/resources/fake_to_snmp.conf} | 18 +-
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
.../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 | 577 ++++++++++++++++
.../SplitClusterPendingJobLifecycleFailoverIT.java | 369 +++++++++++
...plitClusterTerminalZombieJobMasterSwitchIT.java | 608 +++++++++++++++++
.../e2e/TaskDeploymentClassLoaderLeakIT.java | 308 +++++++++
...kDeploymentPrePublicationClassLoaderLeakIT.java | 733 +++++++++++++++++++++
.../FinalCheckpointCloseHoldGate.java | 153 +++++
.../FinalCheckpointCloseHoldSink.java | 39 +-
.../FinalCheckpointCloseHoldSinkFactory.java | 78 +++
.../FinalCheckpointCloseHoldSinkWriter.java | 123 ++++
...ClusterWorkerRestartAfterFinalCheckpointIT.java | 573 ++++++++++++++++
.../batch_fake_to_console_minimal_slot.conf | 18 +-
...ocalfile_close_handshake_failover_template.conf | 78 +++
...equence_to_localfile_corrupted_checkpoint.conf} | 9 +-
...er_batch_fake_to_close_hold_sink_template.conf} | 29 +-
...h_one_pipeline_permanently_failed_template.conf | 104 +++
...le.conf => dynamic_slot_no_capacity_check.conf} | 14 +-
...f => pending_jobs_streaming_unschedulable.conf} | 2 +-
...tream_fake_busy_split_to_console_savepoint.conf | 10 +
...e_to_console_terminal_zombie_master_switch.conf | 20 +-
...eckpoint_trigger_dispatch_failure_template.conf | 71 ++
...ng_fake_to_localfile_committer_cache_leak.conf} | 24 +-
.../serializer/protobuf/ProtoStuffSerializer.java | 13 +-
.../protobuf/ProtoStuffSerializerTest.java | 56 ++
208 files changed, 16524 insertions(+), 1302 deletions(-)
create mode 100644 docs/en/connectors/sink/GcsFile.md
create mode 100644 docs/en/connectors/sink/SNMP.md
create mode 100644 docs/en/developer/contribute-performance-guide.md
create mode 100644 docs/zh/connectors/sink/GcsFile.md
create mode 100644 docs/zh/connectors/sink/SNMP.md
create mode 100644 docs/zh/developer/contribute-performance-guide.md
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/tests/test_benchmark_comparison.py
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-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
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-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/hadoop/ChunkedInputHadoopFileSystemProxy.java
copy
seatunnel-connectors-v2/connector-file/{connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/catalog/FtpFileCatalog.java
=>
connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/catalog/GcsFileCatalog.java}
(64%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/catalog/OssFileCatalogFactory.java
=>
connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/catalog/GcsFileCatalogFactory.java}
(73%)
copy
seatunnel-connectors-v2/connector-file/connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/config/{GcsFileSourceOptions.java
=> GcsFileSinkOptions.java} (93%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSink.java
=>
connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/sink/GcsFileSink.java}
(71%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/sink/LocalFileSinkFactory.java
=>
connector-file-gcs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/gcs/sink/GcsFileSinkFactory.java}
(77%)
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-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
delete mode 100644
seatunnel-connectors-v2/connector-slack/src/test/java/org/apache/seatunnel/connectors/seatunnel/slack/SlackFactoryTest.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
copy
seatunnel-connectors-v2/{connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/DocumentSerializer.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/config/SnmpTargetConfig.java}
(72%)
copy
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/{source/Snmp4jClient.java
=> sink/Snmp4jSetClient.java} (53%)
copy
seatunnel-connectors-v2/connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/{source/SnmpClient.java
=> sink/SnmpSetClient.java} (79%)
copy
seatunnel-connectors-v2/{connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/IntHolder.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSetRequest.java}
(71%)
copy
seatunnel-connectors-v2/{connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/sink/ActivemqSink.java
=>
connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/sink/SnmpSink.java}
(66%)
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
copy
seatunnel-connectors-v2/{connector-iceberg/src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSinkConfigTest.java
=>
connector-snmp/src/test/java/org/apache/seatunnel/connectors/seatunnel/snmp/client/SnmpTargetFactoryTest.java}
(50%)
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
copy
seatunnel-transforms-v2/src/test/java/org/apache/seatunnel/transform/metadata/MetadataTransformFactoryTest.java
=>
seatunnel-connectors-v2/connector-web3j/src/test/java/org/apache/seatunnel/connectors/seatunnel/Web3jFactoryTest.java
(50%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-gcs-e2e/src/test/resources/gcs/{gcs_file_to_assert.conf
=> gcs_file_to_gcs.conf} (63%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-gcs-e2e/src/test/resources/gcs/{gcs_file_to_assert.conf
=> gcs_sink_to_assert.conf} (67%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-fake-e2e =>
connector-snmp-e2e}/pom.xml (91%)
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-google-pubsub-e2e/src/test/resources/pubsub/fake_to_google_pubsub.conf
=> connector-snmp-e2e/src/test/resources/fake_to_snmp.conf} (78%)
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/workerrestart/FinalCheckpointCloseHoldGate.java
copy
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSink.java
(52%)
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-engine/seatunnel-engine-client/src/test/resources/batch_fake_to_console_with_transform_name.conf
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_fake_to_console_minimal_slot.conf
(84%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_fake_to_localfile_close_handshake_failover_template.conf
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/checkpoint-restore-with-stop/{stream_checkpointable_sequence_to_localfile.conf
=> stream_checkpointable_sequence_to_localfile_corrupted_checkpoint.conf} (68%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{allocate-strategy/allocate_strategy_tag2_with_system_load.conf
=> cluster_batch_fake_to_close_hold_sink_template.conf} (61%)
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-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{upload-file/fake_to_console.conf
=> dynamic_slot_no_capacity_check.conf} (83%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{pending_jobs_streaming_lifecycle.conf
=> pending_jobs_streaming_unschedulable.conf} (97%)
copy
seatunnel-engine/seatunnel-engine-server/src/test/resources/stream_fakesource_busy_to_console_savepoint.conf
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fake_busy_split_to_console_savepoint.conf
(64%)
copy
seatunnel-engine/seatunnel-engine-server/src/test/resources/stream_fake_to_inmemory_savepoint_timeout.conf
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/stream_fake_to_console_terminal_zombie_master_switch.conf
(67%)
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
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{stream_fake_to_localfile_savepoint_precondition_template.conf
=> streaming_fake_to_localfile_committer_cache_leak.conf} (73%)
