This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.apache.commons-commons-compress-1.21
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
discard 3ac26c6cd Bump commons-compress from 1.20 to 1.21
add 971af707e [SeaTunnel][Improve]Add sink name in flink starter. (#2728)
add 3b5927584 [hotfix][translation] fix data,time,timestamp type convert
for spark (#2637)
add a357dca36 [Improve][Connector-V2] Refactor hive source & sink
connector (#2708)
add 6129c0256 [Improve][Connector-V2] Refactor hdfs file sink connector
code structure (#2701)
add 90ce3851d [Improve][Connector-V2] Fix kafka connector (#2745)
add e4691f7d3 [Feat][UI] Add themes in the project. (#2753)
add c946eb797 [Feat][UI] Update user service in the project. (#2756)
add ffc6088a7 [Feature][Connector-V2] Add iceberg source connector (#2615)
add 94ed275ba [Feat][UI] Update task service in the project. (#2758)
add 46cf8393b [Feat][UI] Update script service in the project. (#2763)
add d64d452c8 [Improve][e2e] Add driver-jar to lib (#2719)
add f6a13a676 [Connector-V2] [Doc] Add Connector v2 feature doc to website
(#2760)
add a82fa1e7b [hotfix][spark] fix the problem of calling the getData()
method twice (#2764)
add c67acb463 [DEV] [DOC] Fix JDBC connector doc (#2766)
add 745eec0d8 [Feat][UI] Add login and logout function in the project.
(#2769)
add 6db4d7595 [Bug][Core] Fix the bug that can not convert array and map
(#2750)
add 9365d3520 [Bug][Connector-V2] Fix the bug that can not print
SeaTunnelRow correctly (#2749)
add c683bd6ec [Feat][UI] Update login function in the project. (#2773)
add b4d447bb5 [Feat][UI] Add user list function in the project. (#2780)
add cccfa88f7 [connector-v1][doc]Fix inconsistency between document and
code logic (#2776)
add e92e7b728 [Connector-V2] [Kafka] Fix Kafka Streaming problem (#2759)
add 488e561ee [Bug][Connector-V2] Fix error option (#2775)
add b1711c984 fix spark execute exception is not thrown (#2791)
add 563637ebd [Bug][Connector-V2] Fix hive source text table name (#2797)
add 6792e538a [Feat][UI] Add user delete, disable and enable function in
the project. (#2795)
add 79cb09d62 [Improve][e2e] Improve end-to-end testing of connector-v2 in
a multi-engine environment (#2762)
add bc21938e4 [Feat][UI] Add user add and update function in the project.
(#2810)
add 6d9c71469 [Fix] Fix hive source doc (#2804)
add af34beda3 [Improve][Connector-V2] Imporve orc read strategy (#2747)
add 4bb2beb8c [License]Update binary license (#2798)
add efbf793fa [Improve][Connector-V2] Improve mongodb connector (#2778)
add d9a6039fd fix XAConnection being wrongly submitted (#2805)
add ed1ab5ece [Bug][seatunnel-translation-spark] Fix compile version
exception (#2827)
add 32c1c81b2 [Doc][Connector-V2] add Console sink doc (#2822)
add 9f21d4c76 [Bug] [Connector-V2] Fix hive source connector parallelism
not work (#2823)
add 8af7e03e3 [hotfix][build] Connectors packaging don't exclude
connector-http-base (#2818)
add 84b7e3e72 --help according to repair (#2834)
add 853d91492 [Binary-Package]Add script to automatically download plugins
(#2831)
add 4aacbcdd1 [Imporve][Connector-V2] Refactor ftp sink & Add ftp file
source (#2774)
add 5b3957bc5 [Improve][Connector-V2] Improve http connector (#2833)
add 9f59fc187 [Improve][SeaTunnel-Schema] Support parse row type from
config file (#2771)
add fd641d264 [Bug]Ensure that output paths constructed from zip archive
entries are validated to prevent writing files to unexpected locations. (#2843)
add e19bc82f9 [Improve][Connector-V2] Improve read parquet (#2841)
add 76bccbd8c [Binary-Package]The release binary package should contain
seatunnel-starter (#2842)
add 8ff0ba701 [hotfix][connector-v2] fix pulsar source exceptions (#2820)
add f0a1f5013 [Connector-V2] [Clickhouse] Fix Clickhouse Type Mapping and
Spark Map reconvert Bug (#2767)
add 61720306e [Fix][Connector-V2] Fix HiveSource Connector read orc table
error (#2845)
add e568bcf9e [DEV][DOC] Add some hints to the mysql documentation (#2855)
add 2fcbbf464 [Connector-V2] [ElasticSearch] Fix ElasticSearch Connector
V2 Bug (#2817)
add e0459bbab [Fix] [Connector-V2-File] Fix file connector bug (#2858)
add db434adc1 [Feature] [Connector-V2 E2E] Add mysql and postgres e2e test
and bug fix (#2838)
add d661fa011 [Bug][Connector-V2] Fix hive sink bug (#2870)
add 292a75aa7 [translation][Flink]fixed data stream transform to table not
support BigDecimalTypeInfo (#2846)
add da14c2b08 [Doc][Connector-V2] Improve hive sink doc (#2875)
add 857358b95 [Improve][Doc] Update Kafka.md (#2863)
add 018ee0a3d update hive.metastore.version to hive.exec.version (#2879)
add 255533d42 [hotfix] Temporary @Disabled XaGroupOpsImplIT (#2883)
add 3e186a6ed [Examples]remove unexpected examples (#2880)
add d94a874bc Move Handover to common module (#2877)
add 50c08f50d [Feature][seatunnel-text-format] Support text format (#2884)
add 1ece805ab [Improve][Connector-V2]Kudu Sink Connector Support to upsert
row
add 254223fdb [Imporve][Connector-V2]Parameter verification for connector
V2 kafka sink (#2866)
add 2af310ac8 [Improve][DOC] Perfect the connector v2 doc (#2800)
add 12fa644c2 add seatunnel-examples from gitignore (#2892)
add 7622f2899 [Improve][connector-jdbc] Calculate splits only once in
JdbcSourceSplitEnumerator (#2900)
add 3aee11fc1 [Bug][Connector-V2] Fix wechat sink data serialization
(#2856)
add 4d048cc23 [Improve][Connector-V2] Improve orc write strategy to
support all data types (#2860)
add b6f7e773b [Bug][seatunnel-translation-base] Fix Source restore state
NPE (#2878)
add b7d9dde6c [Improve][Connector-v2-Fake]Supports direct definition of
data values(row) (#2839)
add b7f640724 [Code-Improve][Iceberg] Use automatic resource management to
replace 'try - finally' code block. (#2909)
add 8dc1c605e [Feature] [deploy] Add Helm charts (#2903)
add 57342c654 [hotfix][connector][jdbc] fix JDBC split exception (#2904)
add 90041bfd3 Require branches to be up to date before mergin (#2920)
add 0b5a2852f [Bug][connector-file-base] Fix source split assigning reader
to negative number (#2921)
add 1148412b1 [Improve][api][flink] extraction unified method (#2862)
add eaa979a2d [Improve][e2e] Unified e2e IT for Redis (#2924)
add 3da11ce19 [Imporve][Connector-V2] Imporve iotdb connector (#2917)
add 9ba1b2349 [e2e][spark] Upgrade spark image to 2.4.6 (#2932)
add f8dcb92c1 Update .asf.yaml (#2939)
add f907927a3 [Improve][e2e] Improve jdbc driver management (#2770)
add 783b7f48d Bump commons-compress from 1.20 to 1.21
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 (3ac26c6cd)
\
N -- N -- N
refs/heads/dependabot/maven/org.apache.commons-commons-compress-1.21 (783b7f48d)
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:
.asf.yaml | 3 +-
.github/workflows/backend.yml | 3 +-
.gitignore | 2 +
LICENSE | 16 +-
NOTICE | 36 +-
bin/install-plugin.sh | 83 +
config/plugin_config | 92 +
.../helm/seatunnel_flink/Chart.yaml | 14 +-
deploy/helm/seatunnel_flink/README.md | 24 +
.../helm/seatunnel_flink/requirements.yaml | 13 +-
.../helm/seatunnel_flink/templates/flink-conf.yaml | 15 +-
.../seatunnel_flink/templates/seatunnel-flink.yaml | 55 +
deploy/helm/seatunnel_flink/values.yaml | 75 +
.../helm/seatunnel_spark/Chart.yaml | 14 +-
deploy/helm/seatunnel_spark/README.md | 16 +
.../seatunnel_spark/templates/seatunnel-spark.yaml | 43 +
.../helm/seatunnel_spark/templates/spark-conf.yaml | 16 +-
deploy/helm/seatunnel_spark/values.yaml | 59 +
docs/en/connector-v2/sink/Clickhouse.md | 5 +
docs/en/connector-v2/sink/Console.md | 80 +
docs/en/connector-v2/sink/Elasticsearch.md | 19 +-
docs/en/connector-v2/sink/FtpFile.md | 30 +-
docs/en/connector-v2/sink/HdfsFile.md | 44 +-
docs/en/connector-v2/sink/Hive.md | 116 +-
docs/en/connector-v2/sink/Http.md | 31 +-
docs/en/connector-v2/sink/IoTDB.md | 143 +-
docs/en/connector-v2/sink/Jdbc.md | 58 +-
docs/en/connector-v2/sink/LocalFile.md | 8 +-
docs/en/connector-v2/source/FakeSource.md | 8 +
.../source/{LocalFile.md => FtpFile.md} | 69 +-
docs/en/connector-v2/source/HdfsFile.md | 24 +-
docs/en/connector-v2/source/Hive.md | 55 +
docs/en/connector-v2/source/Http.md | 46 +-
docs/en/connector-v2/source/Iceberg.md | 157 +
docs/en/connector-v2/source/IoTDB.md | 69 +-
docs/en/connector-v2/source/Jdbc.md | 40 +-
docs/en/connector-v2/source/LocalFile.md | 24 +-
docs/en/connector-v2/source/OssFile.md | 27 +-
docs/en/connector-v2/source/pulsar.md | 46 +-
docs/en/connector/sink/Jdbc.mdx | 15 +-
docs/en/connector/sink/Kafka.md | 2 +-
docs/en/start/local.mdx | 17 +-
docs/sidebars.js | 3 +-
plugin-mapping.properties | 3 +-
pom.xml | 5 +-
.../apache/seatunnel/flink/FlinkEnvironment.java | 41 +-
.../flink/stream/FlinkStreamExecution.java | 13 +-
.../seatunnel/spark/batch/SparkBatchExecution.java | 6 +-
.../org/apache/seatunnel/common}/Handover.java | 2 +-
.../org/apache/seatunnel/common/config/Common.java | 2 +-
.../apache/seatunnel/common/config/DeployMode.java | 7 +-
.../seatunnel/common/utils/DateTimeUtils.java | 60 +
.../apache/seatunnel/common/utils/DateUtils.java | 56 +
.../apache/seatunnel/common/utils/TimeUtils.java | 54 +
seatunnel-connectors-v2/README.md | 170 +-
seatunnel-connectors-v2/README.zh.md | 97 +-
.../sink/client/ClickhouseSinkWriter.java | 20 +-
.../sink/inject/DateTimeInjectFunction.java | 9 +-
...eInjectFunction.java => MapInjectFunction.java} | 15 +-
.../seatunnel/clickhouse/util/TypeConvertUtil.java | 16 +-
.../seatunnel/common/schema/SeaTunnelSchema.java | 68 +-
.../seatunnel/common/sink/AbstractSinkWriter.java | 2 +-
.../common/source/AbstractSingleSplitSource.java | 2 +-
.../connector/common/schema/SchemaParseTest.java | 2 +
.../src/test/resources/complex.schema.conf | 38 +
.../seatunnel/console/sink/ConsoleSinkWriter.java | 5 +-
.../console/sink/ConsoleSinkWriterIT.java | 4 +-
.../connector-elasticsearch/pom.xml | 6 +
.../elasticsearch/client/EsRestClient.java | 0
.../seatunnel/elasticsearch/config/SinkConfig.java | 0
.../elasticsearch/constant/BulkConfig.java | 0
.../constant/ElasticsearchVersion.java | 0
.../seatunnel/elasticsearch/dto/BulkResponse.java | 0
.../seatunnel/elasticsearch/dto/IndexInfo.java | 0
.../exception/BulkElasticsearchException.java | 0
.../GetElasticsearchVersionException.java | 0
.../serialize/ElasticsearchRowSerializer.java | 9 +-
.../serialize/SeaTunnelRowSerializer.java | 0
.../serialize/index/IndexSerializer.java | 0
.../serialize/index/IndexSerializerFactory.java | 0
.../index/impl/FixedValueIndexSerializer.java | 0
.../index/impl/VariableIndexSerializer.java | 0
.../serialize/type/IndexTypeSerializer.java | 0
.../serialize/type/IndexTypeSerializerFactory.java | 0
.../type/impl/NotIndexTypeSerializer.java | 0
.../type/impl/RequiredIndexTypeSerializer.java | 0
.../elasticsearch/sink/ElasticsearchSink.java | 0
.../sink/ElasticsearchSinkWriter.java | 4 +-
.../state/ElasticsearchAggregatedCommitInfo.java | 0
.../state/ElasticsearchCommitInfo.java | 0
.../state/ElasticsearchSinkState.java | 0
.../seatunnel/elasticsearch/util/RegexUtils.java | 0
.../seatunnel/fake/source/FakeOptions.java} | 24 +-
.../seatunnel/fake/source/FakeRandomData.java | 2 +-
.../seatunnel/fake/source/FakeSource.java | 4 +-
.../seatunnel/fake/source/FakeSourceReader.java | 6 +-
.../FakeRandomDataTest.java | 2 +-
.../pom.xml | 21 +-
.../file/hdfs/sink/BaseHdfsFileSink.java} | 39 +-
.../file/hdfs/source/BaseHdfsFileSource.java} | 16 +-
.../file/hdfs/source/config/HdfsSourceConfig.java | 0
.../connector-file/connector-file-base/pom.xml | 33 +-
.../seatunnel/file/sink/AbstractFileSink.java | 154 -
.../seatunnel/file/sink/BaseFileSink.java | 24 +-
.../seatunnel/file/sink/BaseFileSinkWriter.java | 12 +-
.../file/sink/FileSinkAggregatedCommitter.java | 96 -
.../seatunnel/file/sink/FileSinkState.java | 30 -
.../file/sink/FileSinkWriterWithTransaction.java | 160 -
.../file/sink/TransactionStateFileSinkWriter.java | 160 -
...mitInfo2.java => FileAggregatedCommitInfo.java} | 2 +-
.../{FileCommitInfo2.java => FileCommitInfo.java} | 2 +-
...tter2.java => FileSinkAggregatedCommitter.java} | 14 +-
...eSinkCommitter2.java => FileSinkCommitter.java} | 13 +-
.../seatunnel/file/sink/config/FileSystemType.java | 36 -
.../file/sink/config/TextFileSinkConfig.java | 16 +-
.../file/sink/spi/SinkFileSystemPlugin.java | 55 -
.../{FileSinkState2.java => FileSinkState.java} | 2 +-
.../file/sink/transaction/Transaction.java | 71 -
.../transaction/TransactionStateFileWriter.java | 44 -
.../seatunnel/file/sink/util/FileSystemUtils.java | 41 +-
.../writer/AbstractTransactionStateFileWriter.java | 200 -
.../file/sink/writer/AbstractWriteStrategy.java | 14 +-
.../writer/FileSinkPartitionDirNameGenerator.java | 95 -
.../FileSinkTransactionFileNameGenerator.java | 68 -
.../seatunnel/file/sink/writer/FileWriter.java | 37 -
.../file/sink/writer/OrcWriteStrategy.java | 224 +-
.../file/sink/writer/TextWriteStrategy.java | 17 +-
.../seatunnel/file/sink/writer/Transaction.java | 10 +-
.../file/source/BaseFileSourceReader.java | 5 -
.../file/source/reader/AbstractReadStrategy.java | 3 +
.../file/source/reader/OrcReadStrategy.java | 305 +-
.../file/source/reader/ParquetReadStrategy.java | 238 +-
.../source/split/FileSourceSplitEnumerator.java | 65 +-
.../seatunnel/file/writer/OrcReadStrategyTest.java | 58 +
.../file/writer/ParquetReadStrategyTest.java | 57 +
.../TestFileSinkPartitionDirNameGenerator.java | 66 -
.../TestFileSinkTransactionFileNameGenerator.java | 44 -
.../src/test/resources/test.orc | Bin 0 -> 1959 bytes
.../src/test/resources/test.parquet | Bin 0 -> 3868 bytes
.../connector-file/connector-file-ftp/pom.xml | 5 +
.../seatunnel/file/ftp/config/FtpConf.java | 50 +
.../seatunnel/file/ftp/config/FtpConfig.java} | 11 +-
.../file/{sink/ftp => ftp/sink}/FtpFileSink.java | 35 +-
.../seatunnel/file/ftp/source/FtpFileSource.java} | 27 +-
.../file/ftp/system/SeaTunnelFTPFileSystem.java | 629 +++
.../seatunnel/file/sink/ftp/FtpFileSinkPlugin.java | 71 -
.../seatunnel/file/sink/ftp/config/FtpConfig.java | 25 -
.../file/sink/ftp/filesystem/FtpFileSystem.java | 41 -
.../ftp/filesystem/FtpFileSystemCommitter.java | 57 -
.../seatunnel/file/sink/ftp/util/FtpFileUtils.java | 179 -
.../FtpTransactionStateFileWriteFactory.java | 78 -
.../writer/FtpTxtTransactionStateFileWriter.java | 125 -
.../services/org.apache.hadoop.fs.FileSystem | 12 +-
.../connector-file/connector-file-hadoop/pom.xml | 7 +-
.../seatunnel/file/hdfs/sink/HdfsFileSink.java | 18 +-
.../file/hdfs/sink/HdfsFileSinkPlugin.java | 69 -
.../file/hdfs/sink/filesystem/HdfsFileSystem.java | 40 -
.../sink/filesystem/HdfsFileSystemCommitter.java | 54 -
.../seatunnel/file/hdfs/sink/util/HdfsUtils.java | 138 -
.../writer/HdfsJsonTransactionStateFileWriter.java | 122 -
.../writer/HdfsOrcTransactionStateFileWriter.java | 244 --
.../HdfsParquetTransactionStateFileWriter.java | 169 -
.../HdfsTransactionStateFileWriteFactory.java | 115 -
.../writer/HdfsTxtTransactionStateFileWriter.java | 125 -
.../seatunnel/file/hdfs/source/HdfsFileSource.java | 40 +-
.../hdfs/sink/FileSinkAggregatedCommitterTest.java | 147 -
.../TestHdfsTxtTransactionStateFileWriter.java | 109 -
.../connector-file/connector-file-local/pom.xml | 1 +
.../file/local/source/LocalFileSource.java | 2 +-
seatunnel-connectors-v2/connector-file/pom.xml | 50 +
seatunnel-connectors-v2/connector-hive/pom.xml | 178 +-
.../connectors/seatunnel/hive/config/Constant.java | 23 -
.../seatunnel/hive/config/HiveConfig.java | 47 +
.../seatunnel/hive/config/SourceConfig.java | 29 -
.../seatunnel/hive/sink/HiveCommitInfo.java | 36 -
.../connectors/seatunnel/hive/sink/HiveSink.java | 166 +-
.../hive/sink/HiveSinkAggregatedCommitter.java | 139 -
.../seatunnel/hive/sink/HiveSinkConfig.java | 155 -
.../seatunnel/hive/sink/HiveSinkState.java | 30 -
.../seatunnel/hive/sink/HiveSinkWriter.java | 160 -
.../seatunnel/hive/source/HiveSource.java | 100 +-
.../seatunnel/hive/source/HiveSourceReader.java | 98 -
.../seatunnel/hive/source/HiveSourceSplit.java | 36 -
.../hive/source/HiveSourceSplitEnumerator.java | 126 -
.../seatunnel/hive/source/HiveSourceState.java | 35 -
.../file/reader/format/AbstractReadStrategy.java | 84 -
.../source/file/reader/format/OrcReadStrategy.java | 168 -
.../file/reader/format/ParquetReadStrategy.java | 185 -
.../source/file/reader/format/ReadStrategy.java | 42 -
.../file/reader/format/ReadStrategyFactory.java | 38 -
.../file/reader/format/TextReadStrategy.java | 56 -
.../hive/source/file/reader/type/FileTypeEnum.java | 48 -
.../seatunnel/hive/utils/HiveMetaStoreProxy.java | 45 +-
.../seatunnel/hive/sink/HiveSinkConfigTest.java | 51 -
.../connector-http/connector-http-base/pom.xml | 32 +-
.../seatunnel/http/client/HttpClientProvider.java | 53 +-
.../seatunnel/http/config/HttpConfig.java | 4 +
.../seatunnel/http/config/HttpParameter.java | 18 +
.../seatunnel/http/sink/HttpSinkWriter.java | 11 +-
.../http/source/DeserializationCollector.java | 60 +
.../seatunnel/http/source/HttpSource.java | 24 +-
.../seatunnel/http/source/HttpSourceReader.java | 18 +-
.../source/SimpleTextDeserializationSchema.java} | 25 +-
.../sink/WeChatBotMessageSerializationSchema.java | 71 +
.../wechat/sink/WeChatHttpSinkWriter.java | 70 -
.../seatunnel/wechat/sink/WeChatSink.java | 25 +-
seatunnel-connectors-v2/connector-iceberg/pom.xml | 193 +
.../seatunnel/iceberg/IcebergCatalogFactory.java | 82 +
.../seatunnel/iceberg/IcebergTableLoader.java | 77 +
.../seatunnel/iceberg/config/CommonConfig.java | 79 +
.../seatunnel/iceberg/config/SourceConfig.java | 81 +
.../iceberg/data/DefaultDeserializer.java | 139 +
.../seatunnel/iceberg/data/Deserializer.java} | 8 +-
.../iceberg/data/IcebergRecordProjection.java | 97 +
.../seatunnel/iceberg/data/IcebergTypeMapper.java | 111 +
.../seatunnel/iceberg/source/IcebergSource.java | 175 +
.../source/enumerator/AbstractSplitEnumerator.java | 130 +
.../enumerator/IcebergBatchSplitEnumerator.java | 71 +
.../enumerator/IcebergEnumerationResult.java} | 29 +-
.../enumerator/IcebergEnumeratorPosition.java} | 26 +-
.../enumerator/IcebergSplitEnumeratorState.java} | 25 +-
.../enumerator/IcebergStreamSplitEnumerator.java | 85 +
.../source/enumerator/scan/IcebergScanContext.java | 85 +
.../enumerator/scan/IcebergScanSplitPlanner.java | 207 +
.../scan/IcebergStreamScanStrategy.java} | 34 +-
.../source/reader/IcebergFileScanTaskReader.java | 143 +
.../reader/IcebergFileScanTaskSplitReader.java | 86 +
.../iceberg/source/reader/IcebergSourceReader.java | 145 +
.../source/split/IcebergFileScanTaskSplit.java | 68 +
.../seatunnel/iceberg/TestIcebergMetastore.java | 63 +
.../seatunnel/iotdb/config/SinkConfig.java | 47 +-
.../seatunnel/iotdb/constant/SourceConstants.java | 2 +
.../serialize/DefaultSeaTunnelRowDeserializer.java | 107 +
.../serialize/DefaultSeaTunnelRowSerializer.java | 268 +-
.../iotdb/serialize/SeaTunnelRowDeserializer.java} | 11 +-
.../seatunnel/iotdb/sink/IoTDBSinkClient.java | 2 +-
.../seatunnel/iotdb/sink/IoTDBSinkWriter.java | 13 +-
.../seatunnel/iotdb/source/IoTDBSource.java | 2 +-
.../seatunnel/iotdb/source/IoTDBSourceReader.java | 83 +-
.../seatunnel/iotdb/source/IoTDBSourceSplit.java | 3 +
.../iotdb/source/IoTDBSourceSplitEnumerator.java | 134 +-
.../seatunnel/iotdb/state/IoTDBSourceState.java | 19 +-
seatunnel-connectors-v2/connector-jdbc/pom.xml | 36 +-
.../connection/SimpleJdbcConnectionProvider.java | 3 +
.../internal/dialect/mysql/MySqlTypeMapper.java | 3 +-
.../executor/SimpleBatchStatementExecutor.java | 11 -
.../internal/options/JdbcConnectorOptions.java | 2 +-
.../seatunnel/jdbc/internal/xa/XaGroupOpsImpl.java | 8 +-
.../jdbc/sink/JdbcExactlyOnceSinkWriter.java | 1 +
.../seatunnel/jdbc/sink/JdbcSinkWriter.java | 3 +
.../seatunnel/jdbc/source/JdbcSourceReader.java | 28 +-
.../jdbc/source/JdbcSourceSplitEnumerator.java | 80 +-
.../jdbc/internal/xa/SemanticXidGeneratorTest.java | 49 +
seatunnel-connectors-v2/connector-kafka/pom.xml | 5 +
.../connectors/seatunnel/kafka/config/Config.java | 2 +-
.../serialize/DefaultSeaTunnelRowSerializer.java | 22 +-
.../connectors/seatunnel/kafka/sink/KafkaSink.java | 10 +
.../seatunnel/kafka/sink/KafkaSinkWriter.java | 20 +-
.../seatunnel/kafka/source/ConsumerMetadata.java | 10 +-
.../kafka/source/KafkaConsumerThread.java | 80 +
.../seatunnel/kafka/source/KafkaSource.java | 6 +-
.../seatunnel/kafka/source/KafkaSourceReader.java | 168 +-
.../seatunnel/kafka/source/KafkaSourceSplit.java | 21 +-
.../kafka/source/KafkaSourceSplitEnumerator.java | 67 +-
.../kudu/kuduclient/KuduOutputFormat.java | 66 +-
seatunnel-connectors-v2/connector-mongodb/pom.xml | 6 -
.../seatunnel/mongodb/data/DataTypeValidator.java | 46 +
.../mongodb/data/DefaultDeserializer.java | 55 +
.../seatunnel/mongodb/data/DefaultSerializer.java | 122 +
.../seatunnel/mongodb/data/Deserializer.java} | 10 +-
.../mongodb/data/SeaTunnelRowBsonWriter.java | 326 ++
.../seatunnel/mongodb/data/Serializer.java} | 12 +-
.../seatunnel/mongodb/sink/MongodbSink.java | 4 +-
.../seatunnel/mongodb/sink/MongodbSinkWriter.java | 32 +-
.../seatunnel/mongodb/source/MongodbSource.java | 21 +-
.../mongodb/source/MongodbSourceReader.java | 58 +-
.../seatunnel/pulsar/source/PulsarSource.java | 2 +-
.../source/enumerator/PulsarSplitEnumerator.java | 22 +-
.../pulsar/source/reader/PulsarSourceReader.java | 7 +-
.../source/reader/PulsarSplitReaderThread.java | 1 +
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-connectors/pom.xml | 12 +
.../core/base/utils/CompressionUtils.java | 3 +
.../core/starter/flink/config/FlinkCommon.java | 42 +
.../core/starter/flink/config/FlinkRunMode.java | 5 +
.../execution/AbstractPluginExecuteProcessor.java | 28 +-
.../starter/flink/execution/FlinkExecution.java | 8 +-
.../flink/execution/SinkExecuteProcessor.java | 2 +-
.../spark/command/SparkApiTaskExecuteCommand.java | 1 +
seatunnel-dist/pom.xml | 40 +
seatunnel-dist/release-docs/LICENSE | 961 +----
seatunnel-dist/release-docs/NOTICE | 4514 ++------------------
.../release-docs/licenses/LICENSE-HdrHistogram.txt | 27 -
.../release-docs/licenses/LICENSE-HikariCP.txt | 191 -
.../release-docs/licenses/LICENSE-activation.txt | 131 -
.../release-docs/licenses/LICENSE-aether.txt | 86 -
.../release-docs/licenses/LICENSE-akka.txt | 20 +
.../licenses/LICENSE-antlr4-runtime.txt | 28 -
.../licenses/LICENSE-aopalliance-repackaged.txt | 349 --
.../release-docs/licenses/LICENSE-aopalliance.txt | 18 -
.../release-docs/licenses/LICENSE-asm.txt | 29 -
.../licenses/LICENSE-aspectjweaver.txt | 279 --
.../licenses/LICENSE-asynchttpclient.txt | 13 -
.../release-docs/licenses/LICENSE-avro.txt | 595 +++
.../release-docs/licenses/LICENSE-aws-sdk-java.txt | 53 -
.../release-docs/licenses/LICENSE-calcite.txt | 191 -
.../release-docs/licenses/LICENSE-checker.txt | 413 --
.../licenses/LICENSE-com.sun.jersey.txt | 93 -
...{LICENSE-spark.txt => LICENSE-connons-math.txt} | 336 +-
.../release-docs/licenses/LICENSE-curvesapi.txt | 13 -
.../release-docs/licenses/LICENSE-druid.txt | 336 --
...{LICENSE-i18n-util.txt => LICENSE-grizzled.txt} | 11 +-
.../release-docs/licenses/LICENSE-hadoop.txt | 1801 --------
.../release-docs/licenses/LICENSE-hive2.txt | 582 ---
.../release-docs/licenses/LICENSE-hk2.txt | 13 -
.../release-docs/licenses/LICENSE-hudi.txt | 347 --
.../release-docs/licenses/LICENSE-icu4j.txt | 46 -
.../release-docs/licenses/LICENSE-influxdb.txt | 23 -
.../licenses/LICENSE-jamon-runtime.txt | 154 -
.../release-docs/licenses/LICENSE-janino.txt | 13 -
.../release-docs/licenses/LICENSE-javassist.txt | 203 +-
.../licenses/LICENSE-javax-annootation-api.txt | 263 ++
.../licenses/LICENSE-javax.annotation-api.txt | 131 -
.../release-docs/licenses/LICENSE-javax.inject.txt | 131 -
.../release-docs/licenses/LICENSE-javax.mail.txt | 131 -
.../licenses/LICENSE-javax.servlet-api.txt | 131 -
.../licenses/LICENSE-javax.servlet.jsp-api.txt | 131 -
.../licenses/LICENSE-javax.servlet.jsp.txt | 131 -
.../licenses/LICENSE-javax.ws.rs-api.txt | 131 -
.../release-docs/licenses/LICENSE-jaxb-api.txt | 131 -
.../licenses/LICENSE-jaxb-impl-2.2.3.txt | 131 -
.../release-docs/licenses/LICENSE-jaxrs-api.txt | 637 ---
.../release-docs/licenses/LICENSE-jcodings.txt | 7 -
.../release-docs/licenses/LICENSE-jedis.txt | 22 -
.../release-docs/licenses/LICENSE-jersey.txt | 637 ---
.../release-docs/licenses/LICENSE-jetty.txt | 415 --
.../release-docs/licenses/LICENSE-joni.txt | 7 -
.../release-docs/licenses/LICENSE-jopt-simple.txt | 7 -
.../release-docs/licenses/LICENSE-jsch.txt | 11 -
.../release-docs/licenses/LICENSE-jsoup.txt | 21 -
.../release-docs/licenses/LICENSE-jsr311-api.txt | 131 -
.../licenses/LICENSE-kafka-clients.txt | 330 --
.../release-docs/licenses/LICENSE-kotlin.txt | 284 --
.../release-docs/licenses/LICENSE-kryo-shaded.txt | 11 -
.../{LICENSE-jline.txt => LICENSE-kryo.txt} | 9 +-
.../licenses/LICENSE-leveldbjni-all.txt | 11 -
.../release-docs/licenses/LICENSE-minlog.txt | 4 +
.../release-docs/licenses/LICENSE-mongo-spark.txt | 31 -
.../release-docs/licenses/LICENSE-mongodb.txt | 89 -
.../release-docs/licenses/LICENSE-mybatis.txt | 13 -
.../{LICENSE-j2objc.txt => LICENSE-orc.txt} | 62 +-
.../licenses/LICENSE-osgi-resource-locator.txt | 131 -
.../release-docs/licenses/LICENSE-paranamer.txt | 26 -
...SE-jmockdata.txt => LICENSE-parquet-format.txt} | 17 +-
...NSE-datasketches.txt => LICENSE-parquet-mr.txt} | 53 +-
.../release-docs/licenses/LICENSE-pgjdbc.txt | 23 -
.../licenses/LICENSE-protobuf-java.txt | 9 -
.../release-docs/licenses/LICENSE-protobuf.txt | 32 +
.../release-docs/licenses/LICENSE-re2j.txt | 11 -
.../release-docs/licenses/LICENSE-rhino.txt | 151 -
.../release-docs/licenses/LICENSE-scala.txt | 16 +
.../release-docs/licenses/LICENSE-scopt.txt | 21 +
.../release-docs/licenses/LICENSE-servlet-api.txt | 131 -
.../{LICENSE-slf4j.txt => LICENSE-sjf4j.txt} | 5 +-
.../release-docs/licenses/LICENSE-spoiwo.txt | 8 -
.../release-docs/licenses/LICENSE-spring.txt | 125 -
.../release-docs/licenses/LICENSE-spymemcached.txt | 20 -
.../release-docs/licenses/LICENSE-sqlline.txt | 11 -
.../release-docs/licenses/LICENSE-stax2-api.txt | 9 -
.../release-docs/licenses/LICENSE-tesla-aether.txt | 5 -
.../release-docs/licenses/LICENSE-xmlenc.txt | 9 -
.../release-docs/licenses/LICENSE-xz.txt | 2 +-
.../{LICENSE-hive1.txt => LICENSE-yetus.txt} | 440 +-
.../release-docs/licenses/LICENSE-zstd-jni.txt | 26 -
.../src/main/assembly/assembly-bin-ci.xml | 3 +-
seatunnel-dist/src/main/assembly/assembly-bin.xml | 69 +-
seatunnel-e2e/pom.xml | 3 +-
.../connector-assert-e2e}/pom.xml | 15 +-
.../connector/assertion/FakeSourceToAssertIT.java | 21 +-
.../resources/assertion/fakesource_to_assert.conf | 58 +-
.../src/test/resources/log4j.properties | 0
.../connector-jdbc-it}/pom.xml | 47 +-
.../jdbc/internal/xa/XaGroupOpsImplIT.java | 128 +
.../src/test/resources/log4j.properties | 0
.../connector-redis-e2e}/pom.xml | 16 +-
.../seatunnel/e2e/connector/redis/RedisIT.java | 184 +
.../src/test/resources/log4j.properties | 0
.../src/test/resources/redis-to-redis.conf} | 36 +-
.../pom.xml | 19 +-
.../e2e/common/AbstractFlinkContainer.java | 93 +-
.../e2e/common/AbstractSparkContainer.java | 62 +-
.../apache/seatunnel/e2e/common/TestResource.java | 45 +
.../apache/seatunnel/e2e/common/TestSuiteBase.java | 44 +
.../AbstractTestContainer.java} | 34 +-
.../common/container/ContainerExtendedFactory.java | 10 +-
.../e2e/common/container/TestContainer.java | 18 +-
.../common/container/TestContainersFactory.java | 11 +-
.../flink/AbstractTestFlinkContainer.java} | 44 +-
.../common/container/flink/Flink13Container.java} | 18 +-
.../spark/AbstractTestSparkContainer.java} | 44 +-
.../common/container/spark/Spark2Container.java} | 18 +-
.../common/junit/ContainerTestingExtension.java | 106 +
.../e2e/common/junit/DisabledOnContainer.java | 35 +-
.../junit/TestCaseInvocationContextProvider.java | 140 +
.../e2e/common/junit/TestContainerExtension.java | 11 +-
.../seatunnel/e2e/common/junit/TestContainers.java | 13 +-
.../e2e/common/junit/TestLoggerExtension.java | 79 +
.../e2e/common/{ => util}/ContainerUtil.java | 24 +-
.../src/test/resources/log4j.properties | 0
.../e2e/flink/v2/file/FakeSourceToFileIT.java | 27 -
.../resources/file/fakesource_to_hdfs_json.conf | 70 -
.../resources/file/fakesource_to_hdfs_parquet.conf | 71 -
.../resources/file/fakesource_to_hdfs_text.conf | 71 -
.../apache/seatunnel/e2e/flink/FlinkContainer.java | 5 +
.../pom.xml | 12 +-
.../e2e/flink/v2/iceberg/IcebergSourceIT.java | 165 +
.../src/test/resources/iceberg/iceberg_source.conf | 82 +
.../src/test/resources/log4j.properties | 0
.../e2e/flink/v2/iotdb/FakeSourceToIoTDBIT.java | 128 -
.../seatunnel/e2e/flink/v2/iotdb/IoTDBIT.java | 209 +
...rce_to_iotdb.conf => iotdb_source_to_sink.conf} | 43 +-
.../connector-jdbc-flink-e2e/pom.xml | 40 +-
.../e2e/flink/v2/jdbc/FakeSourceToJdbcIT.java | 18 +-
.../seatunnel/e2e/flink/v2/jdbc/JdbcDmdbIT.java | 15 +-
.../e2e/flink/v2/jdbc/JdbcGreenplumIT.java | 40 +-
.../seatunnel/e2e/flink/v2/jdbc/JdbcMysqlIT.java | 227 +
.../seatunnel/e2e/flink/v2/jdbc/JdbcPhoenixIT.java | 78 +-
.../e2e/flink/v2/jdbc/JdbcPostgresIT.java | 200 +
.../e2e/flink/v2/jdbc/JdbcSourceToConsoleIT.java | 18 +-
.../test/resources/jdbc/init_sql/mysql_init.conf | 221 +
.../resources/jdbc/jdbc_mysql_source_and_sink.conf | 46 +-
.../jdbc/jdbc_mysql_source_and_sink_datatype.conf | 116 +
.../jdbc/jdbc_mysql_source_and_sink_parallel.conf | 54 +-
...mysql_source_and_sink_parallel_upper_lower.conf | 56 +-
.../jdbc/jdbc_mysql_source_and_sink_xa.conf | 54 +
.../jdbc/jdbc_postgres_source_and_sink.conf | 46 +-
.../jdbc_postgres_source_and_sink_parallel.conf | 54 +-
...tgres_source_and_sink_parallel_upper_lower.conf | 56 +-
.../jdbc/jdbc_postgres_source_and_sink_xa.conf | 55 +-
.../connector-mongodb-flink-e2e/pom.xml | 6 -
.../flink/v2/mongodb/FakeSourceToMongodbIT.java | 137 -
.../seatunnel/e2e/flink/v2/mongodb/MongodbIT.java | 228 +
.../flink/v2/mongodb/MongodbSourceToConsoleIT.java | 126 -
...o_mongodb.conf => mongodb_source_and_sink.conf} | 28 +-
.../test/resources/mongodb/mongodb_to_console.conf | 60 -
.../seatunnel/e2e/flink/v2/redis/RedisIT.java | 93 -
.../seatunnel-flink-connector-v2-e2e/pom.xml | 2 +-
.../apache/seatunnel/e2e/flink/FlinkContainer.java | 5 +
.../seatunnel/e2e/flink/sql/FlinkContainer.java | 7 +-
.../e2e/spark/v2/file/FakeSourceToFileIT.java | 28 +-
.../resources/file/fakesource_to_hdfs_parquet.conf | 70 -
...hdfs_json.conf => fakesource_to_local_orc.conf} | 31 +-
..._text.conf => local_orc_source_to_console.conf} | 52 +-
.../pom.xml | 12 +-
.../e2e/flink/v2/iceberg/IcebergSourceIT.java | 164 +
.../src/test/resources/iceberg/iceberg_source.conf | 85 +
.../src/test/resources/log4j.properties | 0
.../e2e/spark/v2/iotdb/FakeSourceToIoTDBIT.java | 127 -
.../seatunnel/e2e/spark/v2/iotdb/IoTDBIT.java | 208 +
.../test/resources/iotdb/fakesource_to_iotdb.conf | 41 +-
.../resources/iotdb/iotdb_source_to_sink.conf} | 43 +-
.../connector-jdbc-spark-e2e/pom.xml | 44 +-
.../seatunnel/e2e/spark/v2/jdbc/JdbcDmdbIT.java | 16 +-
.../e2e/spark/v2/jdbc/JdbcGreenplumIT.java | 41 +-
.../seatunnel/e2e/spark/v2/jdbc/JdbcMysqlIT.java | 227 +
.../seatunnel/e2e/spark/v2/jdbc/JdbcPhoenixIT.java | 80 +-
.../e2e/spark/v2/jdbc/JdbcPostgresIT.java | 200 +
.../test/resources/jdbc/init_sql/mysql_init.conf | 216 +
.../resources/jdbc/jdbc_mysql_source_and_sink.conf | 46 +-
.../jdbc/jdbc_mysql_source_and_sink_datatype.conf | 114 +
.../jdbc/jdbc_mysql_source_and_sink_parallel.conf | 54 +-
...mysql_source_and_sink_parallel_upper_lower.conf | 56 +-
.../jdbc/jdbc_mysql_source_and_sink_xa.conf | 54 +
.../jdbc/jdbc_postgres_source_and_sink.conf | 46 +-
.../jdbc_postgres_source_and_sink_parallel.conf | 54 +-
...tgres_source_and_sink_parallel_upper_lower.conf | 56 +-
.../jdbc/jdbc_postgres_source_and_sink_xa.conf | 55 +-
.../connector-mongodb-spark-e2e/pom.xml | 6 -
.../spark/v2/mongodb/FakeSourceToMongodbIT.java | 137 -
.../seatunnel/e2e/spark/v2/mongodb/MongodbIT.java | 228 +
.../mongodb/mongodb_source_and_sink.conf} | 58 +-
.../seatunnel/e2e/spark/v2/redis/RedisIT.java | 93 -
.../apache/seatunnel/e2e/spark/SparkContainer.java | 5 +
.../seatunnel-spark-connector-v2-e2e/pom.xml | 1 -
.../apache/seatunnel/e2e/spark/SparkContainer.java | 5 +
.../seatunnel-connector-spark-jdbc-e2e/pom.xml | 15 +-
.../seatunnel-flink-connector-v2-example/pom.xml | 26 +-
.../example/flink/v2/FakeToLocalFileExample.java | 51 -
.../flink/v2/SeaTunnelDingTalkApiExample.java | 51 -
.../main/resources/examples/fake_to_console.conf | 1 +
.../main/resources/examples/fake_to_dingtalk.conf | 62 -
.../resources/examples/fakesource_to_file.conf | 73 -
.../seatunnel-spark-connector-v2-example/pom.xml | 5 -
.../spark/v2/SeaTunnelApiToClickHouseExample.java | 30 -
.../resources/examples/spark.batch.clickhouse.conf | 59 -
.../src/main/resources/examples/spark.batch.conf | 4 +-
seatunnel-formats/pom.xml | 1 +
.../format/json/JsonDeserializationSchema.java | 21 +-
.../format/json/JsonSerializationSchema.java | 4 +-
.../seatunnel/format/json/JsonToRowConverters.java | 61 +-
.../seatunnel-format-text}/pom.xml | 18 +-
.../format/text/TextDeserializationSchema.java | 141 +
.../format/text/TextSerializationSchema.java | 92 +
.../format/text/TextFormatSchemaTest.java | 114 +
.../plugin/discovery/AbstractPluginDiscovery.java | 14 +-
seatunnel-server/pom.xml | 15 +-
seatunnel-server/seatunnel-app/pom.xml | 2 +-
.../translation/source/CoordinatedSource.java | 13 +-
.../source/ParallelEnumeratorContext.java | 2 +-
.../translation/source/ParallelSource.java | 13 +-
.../flink/utils/TypeConverterUtils.java | 3 +
.../flink/utils/TypeConverterUtilsTest.java | 3 +-
.../translation/spark/common/Handover.java | 88 -
.../spark/common/InternalRowCollector.java | 1 +
.../common/serialization/InternalRowConverter.java | 98 +-
.../source/batch/ParallelBatchPartitionReader.java | 2 +-
.../spark/common/utils/InstantConverterUtils.java | 51 +
.../spark/common/utils/TypeConverterUtils.java | 6 +-
seatunnel-ui/src/App.tsx | 5 +-
.../dashboard/header/user/use-user-dropdown.ts | 8 +-
seatunnel-ui/src/layouts/dashboard/index.tsx | 6 +-
seatunnel-ui/src/locales/en_US/user-manage.ts | 7 +-
seatunnel-ui/src/main.ts | 4 +
seatunnel-ui/src/service/script/index.ts | 73 +-
seatunnel-ui/src/service/script/types.ts | 29 +-
seatunnel-ui/src/service/service.ts | 18 +-
seatunnel-ui/src/service/task/index.ts | 43 +-
seatunnel-ui/src/service/task/types.ts | 11 +-
seatunnel-ui/src/service/{user => }/types.ts | 29 +-
seatunnel-ui/src/service/user/index.ts | 58 +-
seatunnel-ui/src/service/user/types.ts | 18 +-
seatunnel-ui/src/store/theme/index.ts | 2 +-
seatunnel-ui/src/store/theme/types.ts | 2 +-
.../src/store/user/index.ts | 27 +-
.../src/store/user/types.ts | 7 +-
seatunnel-ui/src/utils/index.ts | 2 -
seatunnel-ui/src/views/login/index.tsx | 17 +-
seatunnel-ui/src/views/login/use-form.ts | 20 +-
.../user-manage/list/components/delete-modal.tsx | 4 +-
.../user-manage/list/components/form-modal.tsx | 38 +-
.../user-manage/list/components/use-form-modal.ts | 52 +-
seatunnel-ui/src/views/user-manage/list/index.tsx | 26 +-
.../src/views/user-manage/list/use-table.ts | 79 +-
seatunnel-ui/vite.config.ts | 10 +-
tools/checkstyle/checkStyle.xml | 2 +-
tools/dependencies/checkLicense.sh | 2 +-
tools/dependencies/known-dependencies.txt | 640 +--
547 files changed, 16063 insertions(+), 25611 deletions(-)
create mode 100644 bin/install-plugin.sh
create mode 100644 config/plugin_config
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=> deploy/helm/seatunnel_flink/Chart.yaml (66%)
create mode 100644 deploy/helm/seatunnel_flink/README.md
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=> deploy/helm/seatunnel_flink/requirements.yaml (66%)
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=> deploy/helm/seatunnel_flink/templates/flink-conf.yaml (66%)
create mode 100644 deploy/helm/seatunnel_flink/templates/seatunnel-flink.yaml
create mode 100644 deploy/helm/seatunnel_flink/values.yaml
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=> deploy/helm/seatunnel_spark/Chart.yaml (66%)
create mode 100644 deploy/helm/seatunnel_spark/README.md
create mode 100644 deploy/helm/seatunnel_spark/templates/seatunnel-spark.yaml
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=> deploy/helm/seatunnel_spark/templates/spark-conf.yaml (66%)
create mode 100644 deploy/helm/seatunnel_spark/values.yaml
create mode 100644 docs/en/connector-v2/sink/Console.md
copy docs/en/connector-v2/source/{LocalFile.md => FtpFile.md} (63%)
create mode 100644 docs/en/connector-v2/source/Hive.md
create mode 100644 docs/en/connector-v2/source/Iceberg.md
rename
{seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader
=> seatunnel-common/src/main/java/org/apache/seatunnel/common}/Handover.java
(97%)
create mode 100644
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DateTimeUtils.java
create mode 100644
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DateUtils.java
create mode 100644
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/TimeUtils.java
copy
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/{DateTimeInjectFunction.java
=> MapInjectFunction.java} (76%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java
(100%)
copy seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/BulkConfig.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/ElasticsearchVersion.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/BulkResponse.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/IndexInfo.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/BulkElasticsearchException.java
(100%)
copy seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/GetElasticsearchVersionException.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/ElasticsearchRowSerializer.java
(92%)
copy seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/SeaTunnelRowSerializer.java
(100%)
copy seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializerFactory.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/FixedValueIndexSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/VariableIndexSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializerFactory.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/NotIndexTypeSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/RequiredIndexTypeSerializer.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java
(98%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
(100%)
copy seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchSinkState.java
(100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ =>
main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/util/RegexUtils.java
(100%)
rename
seatunnel-connectors-v2/{connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HadoopConf.java
=>
connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeOptions.java}
(58%)
copy seatunnel-connectors-v2/connector-file/{connector-file-hadoop =>
connector-file-base-hadoop}/pom.xml (71%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/FtpFileSink.java
=>
connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/BaseHdfsFileSink.java}
(51%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSource.java
=>
connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/BaseHdfsFileSource.java}
(86%)
copy seatunnel-connectors-v2/connector-file/{connector-file-hadoop =>
connector-file-base-hadoop}/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/config/HdfsSourceConfig.java
(100%)
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/AbstractFileSink.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/FileSinkAggregatedCommitter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/FileSinkState.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/FileSinkWriterWithTransaction.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/TransactionStateFileSinkWriter.java
copy
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/{FileAggregatedCommitInfo2.java
=> FileAggregatedCommitInfo.java} (95%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/{FileCommitInfo2.java
=> FileCommitInfo.java} (96%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/{FileSinkAggregatedCommitter2.java
=> FileSinkAggregatedCommitter.java} (87%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/{FileSinkCommitter2.java
=> FileSinkCommitter.java} (84%)
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSystemType.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/spi/SinkFileSystemPlugin.java
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/state/{FileSinkState2.java
=> FileSinkState.java} (95%)
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/transaction/Transaction.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/transaction/TransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/FileSinkPartitionDirNameGenerator.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/FileSinkTransactionFileNameGenerator.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/FileWriter.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/TestFileSinkPartitionDirNameGenerator.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/TestFileSinkTransactionFileNameGenerator.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/test.orc
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/test.parquet
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConf.java
rename
seatunnel-connectors-v2/connector-file/{connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/config/HdfsSourceConfig.java
=>
connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConfig.java}
(72%)
rename
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/{sink/ftp
=> ftp/sink}/FtpFileSink.java (57%)
copy
seatunnel-connectors-v2/connector-file/{connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java
=>
connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSource.java}
(77%)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/FtpFileSinkPlugin.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/config/FtpConfig.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/filesystem/FtpFileSystem.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/filesystem/FtpFileSystemCommitter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/util/FtpFileUtils.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/writer/FtpTransactionStateFileWriteFactory.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/ftp/writer/FtpTxtTransactionStateFileWriter.java
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties
=>
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/resources/META-INF/services/org.apache.hadoop.fs.FileSystem
(66%)
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSinkPlugin.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/filesystem/HdfsFileSystem.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/filesystem/HdfsFileSystemCommitter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/util/HdfsUtils.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/writer/HdfsJsonTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/writer/HdfsOrcTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/writer/HdfsParquetTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/writer/HdfsTransactionStateFileWriteFactory.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/writer/HdfsTxtTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/FileSinkAggregatedCommitterTest.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/TestHdfsTxtTransactionStateFileWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/Constant.java
create mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/SourceConfig.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveCommitInfo.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkAggregatedCommitter.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkConfig.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkState.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceReader.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceSplit.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceSplitEnumerator.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceState.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/AbstractReadStrategy.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/OrcReadStrategy.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/ParquetReadStrategy.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/ReadStrategy.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/ReadStrategyFactory.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/format/TextReadStrategy.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/file/reader/type/FileTypeEnum.java
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/test/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkConfigTest.java
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/DeserializationCollector.java
rename
seatunnel-connectors-v2/{connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveAggregatedCommitInfo.java
=>
connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/SimpleTextDeserializationSchema.java}
(55%)
create mode 100644
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatBotMessageSerializationSchema.java
delete mode 100644
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatHttpSinkWriter.java
create mode 100644 seatunnel-connectors-v2/connector-iceberg/pom.xml
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogFactory.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/SourceConfig.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/DefaultDeserializer.java
rename
seatunnel-connectors-v2/{connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/SeaTunnelRowSerializer.java
=>
connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/Deserializer.java}
(82%)
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergRecordProjection.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergTypeMapper.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/AbstractSplitEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergBatchSplitEnumerator.java
rename
seatunnel-connectors-v2/{connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/FileAggregatedCommitInfo.java
=>
connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergEnumerationResult.java}
(64%)
rename
seatunnel-connectors-v2/{connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/FileCommitInfo.java
=>
connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergEnumeratorPosition.java}
(66%)
rename
seatunnel-connectors-v2/{connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/BaseHiveCommitInfo.java
=>
connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergSplitEnumeratorState.java}
(59%)
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergStreamSplitEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanContext.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java
rename
seatunnel-connectors-v2/{connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/BulkConfig.java
=>
connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergStreamScanStrategy.java}
(55%)
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergFileScanTaskReader.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergFileScanTaskSplitReader.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/split/IcebergFileScanTaskSplit.java
create mode 100644
seatunnel-connectors-v2/connector-iceberg/src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/TestIcebergMetastore.java
create mode 100644
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/DefaultSeaTunnelRowDeserializer.java
copy
seatunnel-connectors-v2/{connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializer.java
=>
connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/SeaTunnelRowDeserializer.java}
(79%)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGeneratorTest.java
create mode 100644
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
create mode 100644
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DataTypeValidator.java
create mode 100644
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DefaultDeserializer.java
create mode 100644
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DefaultSerializer.java
rename
seatunnel-connectors-v2/{connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/PartitionDirNameGenerator.java
=>
connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/Deserializer.java}
(77%)
create mode 100644
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/SeaTunnelRowBsonWriter.java
rename
seatunnel-connectors-v2/{connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializer.java
=>
connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/Serializer.java}
(80%)
create mode 100644
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkCommon.java
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-HdrHistogram.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-HikariCP.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-activation.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-aether.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-akka.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-antlr4-runtime.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-aopalliance-repackaged.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-aopalliance.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-asm.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-aspectjweaver.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-asynchttpclient.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-avro.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-aws-sdk-java.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-calcite.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-checker.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-com.sun.jersey.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-spark.txt =>
LICENSE-connons-math.txt} (52%)
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-curvesapi.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-druid.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-i18n-util.txt =>
LICENSE-grizzled.txt} (52%)
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-hadoop.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-hive2.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-hk2.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-hudi.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-icu4j.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-influxdb.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-jamon-runtime.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-janino.txt
create mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax-annootation-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.annotation-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.inject.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-javax.mail.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.servlet-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.servlet.jsp-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.servlet.jsp.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-javax.ws.rs-api.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jaxb-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-jaxb-impl-2.2.3.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jaxrs-api.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jcodings.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jedis.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jersey.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jetty.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-joni.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jopt-simple.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jsch.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jsoup.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-jsr311-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-kafka-clients.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-kotlin.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-kryo-shaded.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-jline.txt =>
LICENSE-kryo.txt} (57%)
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-leveldbjni-all.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-mongo-spark.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-mongodb.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-mybatis.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-j2objc.txt =>
LICENSE-orc.txt} (86%)
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-osgi-resource-locator.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-paranamer.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-jmockdata.txt =>
LICENSE-parquet-format.txt} (96%)
rename seatunnel-dist/release-docs/licenses/{LICENSE-datasketches.txt =>
LICENSE-parquet-mr.txt} (87%)
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-pgjdbc.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-protobuf-java.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-protobuf.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-re2j.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-rhino.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-scala.txt
create mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-scopt.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-servlet-api.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-slf4j.txt =>
LICENSE-sjf4j.txt} (94%)
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-spoiwo.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-spring.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-spymemcached.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-sqlline.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-stax2-api.txt
delete mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-tesla-aether.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-xmlenc.txt
rename seatunnel-dist/release-docs/licenses/{LICENSE-hive1.txt =>
LICENSE-yetus.txt} (58%)
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-zstd-jni.txt
copy seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e
=> seatunnel-connector-v2-e2e/connector-assert-e2e}/pom.xml (77%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/spi/FileSystem.java
=>
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/src/test/java/org/apache/seatunnel/e2e/connector/assertion/FakeSourceToAssertIT.java
(55%)
copy
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/examples/fake_to_console.conf
=>
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/src/test/resources/assertion/fakesource_to_assert.conf
(50%)
rename
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e =>
seatunnel-connector-v2-e2e/connector-assert-e2e}/src/test/resources/log4j.properties
(100%)
copy seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e
=> seatunnel-connector-v2-e2e/connector-jdbc-it}/pom.xml (66%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-it/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOpsImplIT.java
rename
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e =>
seatunnel-connector-v2-e2e/connector-jdbc-it}/src/test/resources/log4j.properties
(100%)
copy {seatunnel-connectors-v2/connector-file/connector-file-local =>
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e}/pom.xml (81%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/java/org/apache/seatunnel/e2e/connector/redis/RedisIT.java
copy
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e =>
seatunnel-connector-v2-e2e/connector-redis-e2e}/src/test/resources/log4j.properties
(100%)
rename
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/resources/redis/redis_source_and_sink.conf
=>
seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/redis-to-redis.conf}
(58%)
copy seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e
=> seatunnel-connector-v2-e2e}/pom.xml (78%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/TestResource.java
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/TestSuiteBase.java
rename
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/{AbstractContainer.java
=> container/AbstractTestContainer.java} (75%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/transaction/TransactionFileNameGenerator.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/ContainerExtendedFactory.java
(77%)
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/spi/FileSystemCommitter.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/TestContainer.java
(63%)
rename seatunnel-ui/src/utils/regex.ts =>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/TestContainersFactory.java
(84%)
copy
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/{AbstractFlinkContainer.java
=> container/flink/AbstractTestFlinkContainer.java} (77%)
copy
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-flink-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
=>
seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/Flink13Container.java}
(76%)
copy
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/{AbstractSparkContainer.java
=> container/spark/AbstractTestSparkContainer.java} (69%)
copy
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-spark-e2e-base/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
=>
seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/Spark2Container.java}
(74%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/ContainerTestingExtension.java
rename
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileAggregatedCommitInfo2.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/DisabledOnContainer.java
(52%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestCaseInvocationContextProvider.java
rename
seatunnel-connectors-v2/connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchSinkState.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestContainerExtension.java
(71%)
rename
seatunnel-connectors-v2/connector-elasticsearch/src/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/GetElasticsearchVersionException.java
=>
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestContainers.java
(72%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestLoggerExtension.java
rename
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/{
=> util}/ContainerUtil.java (89%)
copy
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e =>
seatunnel-e2e-common}/src/test/resources/log4j.properties (100%)
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_hdfs_json.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_hdfs_parquet.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_hdfs_text.conf
rename
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/{connector-redis-flink-e2e =>
connector-iceberg-flink-e2e}/pom.xml (82%)
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iceberg/IcebergSourceIT.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/src/test/resources/iceberg/iceberg_source.conf
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/{connector-assert-flink-e2e =>
connector-iceberg-flink-e2e}/src/test/resources/log4j.properties (100%)
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iotdb/FakeSourceToIoTDBIT.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iotdb/IoTDBIT.java
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/iotdb/{fakesource_to_iotdb.conf
=> iotdb_source_to_sink.conf} (50%)
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcMysqlIT.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcPostgresIT.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/init_sql/mysql_init.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink.conf
(60%)
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_datatype.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel.conf
(53%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel_upper_lower.conf
(51%)
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_xa.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink.conf
(60%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel.conf
(52%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel_upper_lower.conf
(50%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_xa.conf
(50%)
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/mongodb/FakeSourceToMongodbIT.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/mongodb/MongodbIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/mongodb/MongodbSourceToConsoleIT.java
rename
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/resources/mongodb/{fake_to_mongodb.conf
=> mongodb_source_and_sink.conf} (60%)
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/resources/mongodb/mongodb_to_console.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/fakesource_to_hdfs_parquet.conf
rename
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/{fakesource_to_hdfs_json.conf
=> fakesource_to_local_orc.conf} (78%)
rename
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/{fakesource_to_hdfs_text.conf
=> local_orc_source_to_console.conf} (73%)
rename
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/{connector-redis-spark-e2e =>
connector-iceberg-spark-e2e}/pom.xml (82%)
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iceberg/IcebergSourceIT.java
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/src/test/resources/iceberg/iceberg_source.conf
copy
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e =>
seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e}/src/test/resources/log4j.properties
(100%)
delete mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/iotdb/FakeSourceToIoTDBIT.java
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/iotdb/IoTDBIT.java
rename
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/iotdb/fakesource_to_iotdb.conf
=>
seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/resources/iotdb/iotdb_source_to_sink.conf}
(50%)
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcMysqlIT.java
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcPostgresIT.java
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/init_sql/mysql_init.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink.conf
(61%)
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_datatype.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel.conf
(53%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel_upper_lower.conf
(51%)
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_xa.conf
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink.conf
(60%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel.conf
(52%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel_upper_lower.conf
(50%)
copy
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf
=>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_xa.conf
(50%)
delete mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/mongodb/FakeSourceToMongodbIT.java
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/mongodb/MongodbIT.java
rename
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/redis/redis_source_and_sink.conf
=>
seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/resources/mongodb/mongodb_source_and_sink.conf}
(59%)
delete mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java
delete mode 100644
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/FakeToLocalFileExample.java
delete mode 100644
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelDingTalkApiExample.java
delete mode 100644
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/examples/fake_to_dingtalk.conf
delete mode 100644
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/examples/fakesource_to_file.conf
delete mode 100644
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/java/org/apache/seatunnel/example/spark/v2/SeaTunnelApiToClickHouseExample.java
delete mode 100644
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/resources/examples/spark.batch.clickhouse.conf
copy {seatunnel-connectors-v2/connector-file/connector-file-ftp =>
seatunnel-formats/seatunnel-format-text}/pom.xml (83%)
create mode 100644
seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java
create mode 100644
seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextSerializationSchema.java
create mode 100644
seatunnel-formats/seatunnel-format-text/src/test/java/org/apache/seatunnel/format/text/TextFormatSchemaTest.java
delete mode 100644
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/Handover.java
create mode 100644
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/utils/InstantConverterUtils.java
copy seatunnel-ui/src/service/{user => }/types.ts (78%)
rename
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/exception/HivePluginException.java
=> seatunnel-ui/src/store/user/index.ts (64%)
rename
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/Config.java
=> seatunnel-ui/src/store/user/types.ts (86%)
