This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch 010801_cp_split_by_date
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
omit 682028bf83 Fix review problems
omit 032bfd00b1 Update
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcMysqlSplitIT.java
omit 2195ad655c Update
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java
omit 3b26ccc671 add float and update func
omit de48c4f849 Update docs/en/connector-v2/source/Jdbc.md
omit a4e8053f0c fix ci error
omit 08ca0b4087 update mysql container port
omit 407194e5f3 Add split it
omit 2ddddb7166 Add date type column split support
omit 5a91b56437 Support Split By Date Type Column
add 8d3f8e4627 [Bugfix][CDC Base] Fix NPE caused by adding a table for
restore job (#6145)
add 6822b9c363 [Improve] Ignore useless wrong target slot error (#6135)
add 869417660e [Improve] Improve doris sink to random use be (#6132)
add d37746c7b4 [Test] Fix ConnectorSpecificationCheckTest not work (#5820)
add 56384b9982 [bugfix][example] Solve the problem of example running
failure (#6173)
add 333dc99cab [Improve][Zeta] Add restore when commit failed (#6101)
add 543d2c5086 [Feature][Connector-v2][PulsarSink]Add Pulsar Sink
Connector. (#4382)
add 413fa74500 [Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)
add 66b0f1e1d2 [Feature][Connector] add starrocks save_mode (#6029)
add a4eb5dc542 [Hotfix][Build] Fix build error (#6196)
add 84ce516929 [Feature][Connector] update pgsql catalog for save mode
(#6080)
add e3f6d2fa6c [Improve][API] Add `serialVersionUID` to Column
add aaef22b31b [Feature][Connector-V2][Oracle-cdc]Support for oracle cdc
(#5196)
add e07d086cef [Improve][Test] unify the module name of file oss e2e.
(#6213)
add 6a83169c54 [Feature][doc] Add V2 connector jdbc document parameter can
speed up data import PR (#6176)
add fc2d80382a [Feature][Connector-V2][Doris] Add Doris ConnectorV2 Source
(#6161)
add f14617f09a [Improve][Test] Reduce repeated catalog test times (#6207)
add f56855098b [Feature] Support `uuid` in postgres jdbc (#6185)
add 3cb34c2b71 [Feature][Oracle-CDC] Support read no primary key table
(#6209)
add b7f06ec6d9 [Hotfix][Oracle-CDC] Fix jdbc setFetchSize error (#6210)
add 74cfe1995f [Hotfix][Oracle-CDC] Fix state recovery error when
switching a single table to multiple tables (#6211)
add 919a91032a [Improve][Oracle-CDC] Clean unused code (#6212)
add 81c51073bf [Feature][Connector]add s3file save mode function (#6131)
add 88d1bfdfa8 [Fix][Zeta] Fix start with savepoint with no checkpoint
file error (#6215)
add ba572ebedd [CI] Make sure notify_test_workflow.yml error will be
throwed (#6226)
add c69da93b87 [Improve] Extend `SupportResourceShare` to spark/flink
(#5847)
add fa5b7d3d83 [Improve][HttpConnector]Increase custom configuration
timeout. (#6223)
add 59f60b9f73 [Hotfix][Zeta] Fix job can not restore when last checkpoint
failed (#6193)
add ac7f23c964 Support Split By Date Type Column
add a5f727da1a Add date type column split support
add 7da22a53b9 Add split it
add 83559dc2b7 update mysql container port
add 4ae8b7a7c2 fix ci error
add dd4971a1b7 Update docs/en/connector-v2/source/Jdbc.md
add 975c9fe171 add float and update func
add 9e01158ee4 Update
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java
add a15bd6fd87 Update
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcMysqlSplitIT.java
add 0a6ae77eb2 Fix review problems
add ee57eddcfb Add split test case
add 5607ac142e rebase dev code
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (682028bf83)
\
N -- N -- N refs/heads/010801_cp_split_by_date (5607ac142e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/backend.yml | 2 +-
.github/workflows/notify_test_workflow.yml | 2 +-
.../connector-v2/Error-Quick-Reference-Manual.md | 3 +
docs/en/connector-v2/sink/Http.md | 2 +
docs/en/connector-v2/sink/Jdbc.md | 19 +-
docs/en/connector-v2/sink/Kingbase.md | 1 +
docs/en/connector-v2/sink/Mysql.md | 9 +-
docs/en/connector-v2/sink/OceanBase.md | 3 +-
docs/en/connector-v2/sink/Oracle.md | 9 +-
docs/en/connector-v2/sink/PostgreSql.md | 148 ++-
docs/en/connector-v2/sink/Pulsar.md | 177 +++
docs/en/connector-v2/sink/S3File.md | 80 +-
docs/en/connector-v2/sink/Snowflake.md | 3 +-
docs/en/connector-v2/sink/SqlServer.md | 1 +
docs/en/connector-v2/sink/StarRocks.md | 95 +-
docs/en/connector-v2/sink/Vertica.md | 1 +
docs/en/connector-v2/source/Doris.md | 162 +++
docs/en/connector-v2/source/Http.md | 2 +
docs/en/connector-v2/source/Oracle-CDC.md | 266 ++++
docs/en/connector-v2/source/PostgreSQL.md | 44 +-
plugin-mapping.properties | 3 +
seatunnel-api/pom.xml | 2 -
.../api/sink/SupportMultiTableSinkWriter.java | 4 +
.../seatunnel/api/sink/SupportResourceShare.java | 8 +-
.../api/table/catalog/MetadataColumn.java | 1 +
.../api/table/catalog/PhysicalColumn.java | 2 +
.../cdc/base/source/IncrementalSource.java | 18 +
.../connector-cdc/connector-cdc-oracle/pom.xml | 99 ++
.../connector/oracle/OracleErrorHandler.java | 106 ++
.../LogMinerStreamingChangeEventSource.java | 540 ++++++++
.../oracle/logminer/TransactionalBuffer.java | 1325 ++++++++++++++++++++
.../cdc/oracle/config/OracleSourceConfig.java | 99 ++
.../oracle/config/OracleSourceConfigFactory.java | 187 +++
.../seatunnel/cdc/oracle/source/OracleDialect.java | 124 ++
.../cdc/oracle/source/OracleIncrementalSource.java | 157 +++
.../source/OracleIncrementalSourceFactory.java | 110 ++
.../source/OraclePooledDataSourceFactory.java | 43 +
.../cdc/oracle/source/OracleSourceOptions.java | 56 +
.../source/eumerator/OracleChunkSplitter.java | 124 ++
.../cdc/oracle/source/offset/RedoLogOffset.java | 121 ++
.../oracle/source/offset/RedoLogOffsetFactory.java | 79 ++
.../reader/fetch/OracleSourceFetchTaskContext.java | 320 +++++
.../fetch/logminer/OracleRedoLogFetchTask.java | 176 +++
.../reader/fetch/scan/OracleSnapshotFetchTask.java | 205 +++
.../fetch/scan/OracleSnapshotSplitReadTask.java | 298 +++++
.../SnapshotSplitChangeEventSourceContext.java | 55 +
.../cdc/oracle/utils/OracleConnectionUtils.java | 121 ++
.../seatunnel/cdc/oracle/utils/OracleSchema.java | 89 ++
.../cdc/oracle/utils/OracleTypeUtils.java | 78 ++
.../seatunnel/cdc/oracle/utils/OracleUtils.java | 515 ++++++++
.../source/OracleIncrementalSourceFactoryTest.java | 14 +-
seatunnel-connectors-v2/connector-cdc/pom.xml | 1 +
.../MultiTableSinkAggregatedCommitter.java | 21 +-
.../multitablesink/MultiTableSinkWriter.java | 8 +-
seatunnel-connectors-v2/connector-doris/pom.xml | 12 +
.../connectors/doris/backend/BackendClient.java | 254 ++++
.../connectors/doris/config/DorisConfig.java | 14 +-
.../connectors/doris/config/DorisOptions.java | 10 +
.../doris/exception/DorisConnectorErrorCode.java | 10 +-
.../connectors/doris/rest/PartitionDefinition.java | 148 +++
.../connectors/doris/rest/RestService.java | 337 ++++-
.../connectors/doris/rest/models/Field.java | 134 ++
.../connectors/doris/rest/models/QueryPlan.java | 70 ++
.../connectors/doris/rest/models/Schema.java | 108 ++
.../connectors/doris/rest/models/Tablet.java | 80 ++
.../doris/sink/writer/DorisSinkWriter.java | 19 +-
.../doris/sink/writer/DorisStreamLoad.java | 29 +-
.../connectors/doris/sink/writer/RecordBuffer.java | 9 +-
.../connectors/doris/source/DorisSource.java | 87 ++
.../doris/source/DorisSourceFactory.java | 158 +++
.../connectors/doris/source/DorisSourceState.java | 22 +-
.../doris/source/reader/DorisSourceReader.java | 108 ++
.../doris/source/reader/DorisValueReader.java | 269 ++++
.../doris/source/serialization/Routing.java | 70 ++
.../doris/source/serialization/RowBatch.java | 525 ++++++++
.../doris/source/split/DorisSourceSplit.java | 70 ++
.../source/split/DorisSourceSplitEnumerator.java | 182 +++
.../connectors/doris/util/DorisCatalogUtil.java | 4 +
.../connectors/doris/util/SchemaUtils.java | 50 +
.../file/hadoop/HadoopFileSystemProxy.java | 19 +
.../seatunnel/file/s3/catalog/S3FileCatalog.java | 127 ++
.../file/s3/catalog/S3FileCatalogFactory.java} | 26 +-
.../seatunnel/file/s3/config/S3Conf.java | 25 +
.../seatunnel/file/s3/config/S3ConfigOptions.java | 23 +
.../seatunnel/file/s3/sink/S3FileSink.java | 50 +-
.../seatunnel/file/s3/sink/S3FileSinkFactory.java | 39 +
.../seatunnel/http/client/HttpClientProvider.java | 25 +-
.../seatunnel/http/config/HttpConfig.java | 14 +
.../seatunnel/http/config/HttpParameter.java | 8 +
.../seatunnel/jdbc/catalog/dm/DamengCatalog.java | 4 +-
.../jdbc/catalog/oracle/OracleCatalog.java | 18 +
.../catalog/oracle/OracleDataTypeConvertor.java | 3 +
.../jdbc/catalog/oracle/OracleURLParser.java | 2 +-
.../jdbc/catalog/psql/PostgresCatalog.java | 13 +
.../catalog/psql/PostgresDataTypeConvertor.java | 3 +-
.../seatunnel/jdbc/catalog/utils/CatalogUtils.java | 3 +
.../internal/dialect/psql/PostgresTypeMapper.java | 2 +
.../connectors/seatunnel/jdbc/sink/JdbcSink.java | 4 +-
.../seatunnel/jdbc/sink/JdbcSinkWriter.java | 13 +-
.../seatunnel/pulsar/config/PulsarConfigUtil.java | 116 +-
.../seatunnel/pulsar/config/PulsarSemantics.java | 22 +-
.../seatunnel/pulsar/config/SinkProperties.java | 97 ++
.../pulsar/exception/PulsarConnectorErrorCode.java | 5 +-
.../seatunnel/pulsar/sink/PulsarSink.java | 99 ++
.../seatunnel/pulsar/sink/PulsarSinkCommitter.java | 83 ++
.../seatunnel/pulsar/sink/PulsarSinkFactory.java | 61 +
.../seatunnel/pulsar/sink/PulsarSinkWriter.java | 263 ++++
.../pulsar/source/reader/PulsarSourceReader.java | 3 +-
.../pulsar/state/PulsarAggregatedCommitInfo.java | 16 +-
.../seatunnel/pulsar/state/PulsarCommitInfo.java | 19 +-
.../seatunnel/pulsar/state/PulsarSinkState.java | 19 +-
.../starrocks/catalog/StarRocksCatalog.java | 65 +-
.../starrocks/catalog/StarRocksCatalogFactory.java | 4 +-
.../seatunnel/starrocks/config/SinkConfig.java | 7 +-
.../starrocks/config/StarRocksSinkOptions.java | 24 +-
.../seatunnel/starrocks/sink/StarRocksSink.java | 67 +-
.../starrocks/sink/StarRocksSinkFactory.java | 57 +-
.../starrocks/catalog/StarRocksCatalogTest.java | 2 +-
.../seatunnel-flink-15-starter/pom.xml | 36 +-
.../flink/multitable/MultiTableSinkTest.java | 84 ++
.../config/fake_to_inmemory_multi_table.conf | 48 +-
.../seatunnel-spark-3-starter/pom.xml | 16 +
.../spark/multitable/MultiTableSinkTest.java | 94 ++
.../config/fake_to_inmemory_multi_table.conf | 52 +-
seatunnel-core/seatunnel-starter/pom.xml | 25 +
.../seatunnel/multitable/MultiTableSinkTest.java | 85 ++
.../config/fake_to_inmemory_multi_table.conf | 48 +-
seatunnel-dist/pom.xml | 7 +-
.../connector/ConnectorSpecificationCheckTest.java | 8 +
.../pom.xml | 46 +-
.../seatunnel/cdc/oracle/OracleCDCIT.java | 577 +++++++++
.../src/test/resources/ddl/column_type_test.sql | 265 ++++
.../src/test/resources/log4j2-test.properties | 29 +
.../src/test/resources/oraclecdc_to_console.conf | 64 +
..._to_oracle_with_multi_table_mode_one_table.conf | 64 +
..._to_oracle_with_multi_table_mode_two_table.conf | 64 +
.../oraclecdc_to_oracle_with_no_primary_key.conf | 66 +
.../e2e/connector/doris/AbstractDorisIT.java | 16 +-
.../seatunnel/e2e/connector/doris/DorisIT.java | 293 +++++
.../e2e/connector/doris/GenerateTestData.java | 126 ++
.../src/test/resources/doris_source_and_sink.conf | 50 +
.../connector/elasticsearch/ElasticsearchIT.java | 5 +-
.../connector-file-oss-e2e/pom.xml | 1 +
.../connectors/seatunnel/jdbc/JdbcPostgresIT.java | 132 ++
.../connectors/seatunnel/jdbc/JdbcSqlServerIT.java | 7 +-
.../resources/jdbc_postgres_source_and_sink.conf | 2 +-
.../jdbc_postgres_source_and_sink_parallel.conf | 6 +-
...tgres_source_and_sink_parallel_upper_lower.conf | 6 +-
.../jdbc_postgres_source_and_sink_xa.conf | 6 +-
.../seatunnel/jdbc/JdbcMySqlCreateTableIT.java | 9 +-
.../seatunnel/jdbc/JdbcSqlServerCreateTableIT.java | 9 +-
.../seatunnel/jdbc/JdbcOracleLowercaseTableIT.java | 8 +-
.../seatunnel/jdbc/JdbcMySqlSaveModeCatalogIT.java | 8 +-
.../seatunnel/jdbc/JdbcMysqlSplitIT.java | 183 ++-
.../test/resources/avro/kafka_avro_to_assert.conf | 3 -
.../e2e/connector/pulsar/PulsarSinkIT.java | 138 ++
.../src/test/resources/fake_to_pulsar.conf} | 69 +-
.../connector-starrocks-e2e/pom.xml | 9 +
.../e2e/connector/starrocks/StarRocksIT.java | 132 +-
.../starrocks-thrift-to-starrocks-streamload.conf | 6 +-
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
.../container/seatunnel/SeaTunnelContainer.java | 1 +
.../inmemory/InMemoryAggregatedCommitInfo.java | 12 +-
.../sink/inmemory/InMemoryAggregatedCommitter.java | 78 ++
.../e2e/sink/inmemory/InMemoryCommitInfo.java | 12 +-
.../e2e/sink/inmemory/InMemoryConnection.java | 12 +-
.../InMemoryMultiTableResourceManager.java | 27 +-
.../seatunnel/e2e/sink/inmemory/InMemorySink.java | 64 +
.../e2e/sink/inmemory/InMemorySinkFactory.java | 36 +-
.../e2e/sink/inmemory/InMemorySinkWriter.java | 82 ++
.../seatunnel/e2e/sink/inmemory/InMemoryState.java | 12 +-
.../seatunnel/engine/e2e/JobExecutionIT.java | 27 +
.../org/apache/seatunnel/engine/e2e/RestApiIT.java | 8 +-
.../resources/batch_last_checkpoint_error.conf | 91 ++
.../server/checkpoint/CheckpointCoordinator.java | 33 +-
.../server/checkpoint/CheckpointManager.java | 28 +-
.../engine/server/dag/physical/SubPlan.java | 4 +-
.../opeartion/ReleaseSlotOperation.java | 12 +-
.../server/task/SinkAggregatedCommitterTask.java | 19 +
.../engine/server/task/flow/SinkFlowLifeCycle.java | 16 +
.../engine/server/checkpoint/SavePointTest.java | 72 +-
.../engine/server/master/JobMasterTest.java | 96 +-
.../engine/server/master/JobMetricsTest.java | 1 -
.../resourcemanager/ResourceManagerTest.java | 13 +-
.../seatunnel-engine-examples/pom.xml | 6 +
.../discovery/AbstractPluginDiscoveryTest.java | 2 +-
.../home/connectors/plugin-mapping.properties | 1 +
seatunnel-shade/pom.xml | 2 +
seatunnel-shade/seatunnel-arrow-5.0/pom.xml | 138 ++
seatunnel-shade/seatunnel-thrift-service/pom.xml | 102 ++
.../flink/sink/FlinkGlobalCommitter.java | 23 +
.../translation/flink/sink/FlinkSinkWriter.java | 19 +
.../spark/sink/writer/SparkDataSourceWriter.java | 14 +
.../spark/sink/writer/SparkDataWriter.java | 22 +
.../spark/sink/SeaTunnelBatchWrite.java | 16 +
.../spark/sink/write/SeaTunnelSparkDataWriter.java | 22 +
196 files changed, 13552 insertions(+), 841 deletions(-)
create mode 100644 docs/en/connector-v2/sink/Pulsar.md
create mode 100644 docs/en/connector-v2/source/Doris.md
create mode 100644 docs/en/connector-v2/source/Oracle-CDC.md
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/OracleErrorHandler.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/TransactionalBuffer.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/config/OracleSourceConfig.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/config/OracleSourceConfigFactory.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleDialect.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OraclePooledDataSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/eumerator/OracleChunkSplitter.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/offset/RedoLogOffset.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/offset/RedoLogOffsetFactory.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/logminer/OracleRedoLogFetchTask.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotFetchTask.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/SnapshotSplitChangeEventSourceContext.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleConnectionUtils.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleSchema.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleTypeUtils.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactoryTest.java
(71%)
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/backend/BackendClient.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/PartitionDefinition.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/models/Field.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/models/QueryPlan.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/models/Schema.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/models/Tablet.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/DorisSource.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/DorisSourceFactory.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportResourceShare.java
=>
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/DorisSourceState.java
(61%)
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/reader/DorisSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/reader/DorisValueReader.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/serialization/Routing.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/serialization/RowBatch.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/split/DorisSourceSplit.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/split/DorisSourceSplitEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/SchemaUtils.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/catalog/S3FileCatalog.java
copy
seatunnel-connectors-v2/{connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalogFactory.java
=>
connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/catalog/S3FileCatalogFactory.java}
(64%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportResourceShare.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarSemantics.java
(63%)
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/SinkProperties.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSink.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkCommitter.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkWriter.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarAggregatedCommitInfo.java
(71%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarCommitInfo.java
(69%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarSinkState.java
(69%)
create mode 100644
seatunnel-core/seatunnel-flink-starter/seatunnel-flink-15-starter/src/test/java/org/apache/seatunnel/core/starter/flink/multitable/MultiTableSinkTest.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-thrift-to-starrocks-streamload.conf
=>
seatunnel-core/seatunnel-flink-starter/seatunnel-flink-15-starter/src/test/resources/config/fake_to_inmemory_multi_table.conf
(51%)
create mode 100644
seatunnel-core/seatunnel-spark-starter/seatunnel-spark-3-starter/src/test/java/org/apache/seatunnel/core/starter/spark/multitable/MultiTableSinkTest.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-thrift-to-starrocks-streamload.conf
=>
seatunnel-core/seatunnel-spark-starter/seatunnel-spark-3-starter/src/test/resources/config/fake_to_inmemory_multi_table.conf
(51%)
create mode 100644
seatunnel-core/seatunnel-starter/src/test/java/org/apache/seatunnel/core/starter/seatunnel/multitable/MultiTableSinkTest.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-thrift-to-starrocks-streamload.conf
=>
seatunnel-core/seatunnel-starter/src/test/resources/config/fake_to_inmemory_multi_table.conf
(51%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-file-oss-e2e =>
connector-cdc-oracle-e2e}/pom.xml (69%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/ddl/column_type_test.sql
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/log4j2-test.properties
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_console.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_one_table.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_two_table.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_no_primary_key.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/GenerateTestData.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/resources/doris_source_and_sink.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/PulsarSinkIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/avro/kafka_avro_to_assert.conf
=> connector-pulsar-e2e/src/test/resources/fake_to_pulsar.conf} (52%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryAggregatedCommitInfo.java
(71%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryAggregatedCommitter.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryCommitInfo.java
(71%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryConnection.java
(71%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportResourceShare.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryMultiTableResourceManager.java
(58%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemorySink.java
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalogFactory.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemorySinkFactory.java
(52%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemorySinkWriter.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSinkWriter.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/sink/inmemory/InMemoryState.java
(71%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_last_checkpoint_error.conf
create mode 100644 seatunnel-shade/seatunnel-arrow-5.0/pom.xml
create mode 100644 seatunnel-shade/seatunnel-thrift-service/pom.xml
