This is an automated email from the ASF dual-hosted git repository.
dijiekstra pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from f65f44f44 [Improve][Connector-V2][Kafka] Support to specify multiple
partition keys (#3230)
add e294ce26d [Chore]Remove ConnectorV1 from the dev branch (#3450)
No new revisions were added by this update.
Summary of changes:
config/plugin_config | 42 -
deploy/docker/flink/README.md | 39 -
deploy/docker/flink/config/application.conf | 42 -
deploy/docker/flink/config/flink-conf.yaml | 18 -
deploy/docker/flink/docker-compose.yaml | 59 --
deploy/docker/spark/.env | 19 -
deploy/docker/spark/README.md | 10 -
deploy/docker/spark/config/application.conf | 41 -
deploy/docker/spark/docker-compose.yaml | 57 --
deploy/helm/seatunnel_flink/Chart.yaml | 22 -
deploy/helm/seatunnel_flink/README.md | 24 -
deploy/helm/seatunnel_flink/requirements.yaml | 21 -
.../helm/seatunnel_flink/templates/flink-conf.yaml | 23 -
.../seatunnel_flink/templates/seatunnel-flink.yaml | 55 --
deploy/helm/seatunnel_flink/values.yaml | 75 --
deploy/helm/seatunnel_spark/Chart.yaml | 22 -
deploy/helm/seatunnel_spark/README.md | 16 -
.../seatunnel_spark/templates/seatunnel-spark.yaml | 43 -
.../helm/seatunnel_spark/templates/spark-conf.yaml | 24 -
deploy/helm/seatunnel_spark/values.yaml | 59 --
docs/en/concept/config.md | 4 +-
docs/en/connector/flink-sql/ElasticSearch.md | 50 --
docs/en/connector/flink-sql/Jdbc.md | 67 --
docs/en/connector/flink-sql/Kafka.md | 76 --
docs/en/connector/flink-sql/usage.md | 277 ------
docs/en/connector/sink/Assert.md | 106 ---
docs/en/connector/sink/Clickhouse.md | 148 ----
docs/en/connector/sink/ClickhouseFile.md | 164 ----
docs/en/connector/sink/Console.mdx | 103 ---
docs/en/connector/sink/Doris.mdx | 176 ----
docs/en/connector/sink/Druid.md | 106 ---
docs/en/connector/sink/Elasticsearch.mdx | 120 ---
docs/en/connector/sink/Email.md | 103 ---
docs/en/connector/sink/File.mdx | 192 -----
docs/en/connector/sink/Hbase.md | 73 --
docs/en/connector/sink/Hive.md | 72 --
docs/en/connector/sink/Hudi.md | 43 -
docs/en/connector/sink/Iceberg.md | 70 --
docs/en/connector/sink/InfluxDB.md | 90 --
docs/en/connector/sink/Jdbc.mdx | 213 -----
docs/en/connector/sink/Kafka.mdx | 133 ---
docs/en/connector/sink/Kudu.md | 46 -
docs/en/connector/sink/MongoDB.md | 51 --
docs/en/connector/sink/Phoenix.md | 55 --
docs/en/connector/sink/Redis.md | 95 ---
docs/en/connector/sink/Tidb.md | 88 --
docs/en/connector/sink/common-options.md | 45 -
docs/en/connector/source/Druid.md | 67 --
docs/en/connector/source/Elasticsearch.md | 64 --
docs/en/connector/source/Fake.mdx | 203 -----
docs/en/connector/source/FeishuSheet.md | 61 --
docs/en/connector/source/File.mdx | 124 ---
docs/en/connector/source/Hbase.md | 46 -
docs/en/connector/source/Hive.md | 66 --
docs/en/connector/source/Http.md | 63 --
docs/en/connector/source/Hudi.md | 78 --
docs/en/connector/source/Iceberg.md | 61 --
docs/en/connector/source/InfluxDB.md | 89 --
docs/en/connector/source/Jdbc.mdx | 207 -----
docs/en/connector/source/Kafka.mdx | 179 ----
docs/en/connector/source/Kudu.md | 45 -
docs/en/connector/source/MongoDB.md | 64 --
docs/en/connector/source/Phoenix.md | 60 --
docs/en/connector/source/Redis.md | 95 ---
docs/en/connector/source/Socket.mdx | 106 ---
docs/en/connector/source/Tidb.md | 68 --
docs/en/connector/source/Webhook.md | 44 -
docs/en/connector/source/common-options.mdx | 89 --
docs/en/connector/source/neo4j.md | 145 ----
docs/en/start/docker.md | 8 -
docs/en/start/kubernetes.mdx | 270 ------
docs/en/start/local.mdx | 165 ----
docs/sidebars.js | 77 --
pom.xml | 1 -
seatunnel-connectors/pom.xml | 52 --
.../flink-sql-connector-elasticsearch-6/pom.xml | 36 -
.../flink-sql-connector-elasticsearch-7/pom.xml | 36 -
.../flink-sql-connector-jdbc/pom.xml | 35 -
.../flink-sql-connector-kafka/pom.xml | 37 -
.../seatunnel-connectors-flink-sql/pom.xml | 44 -
.../seatunnel-connectors-flink/pom.xml | 114 ---
.../seatunnel-connector-flink-assert/pom.xml | 44 -
.../seatunnel/flink/assertion/AssertExecutor.java | 105 ---
.../flink/assertion/rule/AssertFieldRule.java | 64 --
.../flink/assertion/rule/AssertRuleParser.java | 92 --
.../seatunnel/flink/assertion/sink/AssertSink.java | 117 ---
.../flink/assertion/AssertExecutorTest.java | 113 ---
.../flink/assertion/rule/AssertRuleParserTest.java | 85 --
.../seatunnel-connector-flink-clickhouse/pom.xml | 62 --
.../seatunnel/flink/clickhouse/ConfigKey.java | 109 ---
.../clickhouse/pojo/ClickhouseFileCopyMethod.java | 42 -
.../flink/clickhouse/pojo/DistributedEngine.java | 57 --
.../seatunnel/flink/clickhouse/pojo/IntHolder.java | 35 -
.../seatunnel/flink/clickhouse/pojo/Shard.java | 131 ---
.../flink/clickhouse/pojo/ShardMetadata.java | 134 ---
.../flink/clickhouse/sink/ClickhouseBatchSink.java | 144 ----
.../clickhouse/sink/ClickhouseFileBatchSink.java | 192 -----
.../sink/ClickhouseFileOutputFormat.java | 261 ------
.../clickhouse/sink/ClickhouseOutputFormat.java | 231 -----
.../sink/client/ClickhouseBatchStatement.java | 51 --
.../clickhouse/sink/client/ClickhouseClient.java | 242 ------
.../flink/clickhouse/sink/client/ShardRouter.java | 102 ---
.../clickhouse/sink/file/ClickhouseTable.java | 117 ---
.../flink/clickhouse/sink/file/FileTransfer.java | 31 -
.../clickhouse/sink/file/ScpFileTransfer.java | 115 ---
.../sink/inject/ArrayInjectFunction.java | 38 -
.../sink/inject/BigDecimalInjectFunction.java | 34 -
.../sink/inject/ClickhouseFieldInjectFunction.java | 46 -
.../clickhouse/sink/inject/DateInjectFunction.java | 39 -
.../sink/inject/DateTimeInjectFunction.java | 39 -
.../sink/inject/DoubleInjectFunction.java | 42 -
.../sink/inject/FloatInjectFunction.java | 39 -
.../clickhouse/sink/inject/IntInjectFunction.java | 39 -
.../clickhouse/sink/inject/LongInjectFunction.java | 37 -
.../sink/inject/StringInjectFunction.java | 38 -
.../flink/clickhouse/sink/ClickhouseFileTest.java | 60 --
.../seatunnel-connector-flink-console/pom.xml | 44 -
.../seatunnel/flink/console/sink/ConsoleSink.java | 102 ---
.../seatunnel-connector-flink-doris/pom.xml | 47 --
.../flink/doris/sink/DorisOutputFormat.java | 230 -----
.../seatunnel/flink/doris/sink/DorisSink.java | 135 ---
.../flink/doris/sink/DorisSinkFunction.java | 70 --
.../flink/doris/sink/DorisStreamLoad.java | 172 ----
.../seatunnel/flink/doris/sink/RespContent.java | 297 -------
.../seatunnel-connector-flink-druid/pom.xml | 49 --
.../flink/druid/sink/DruidOutputFormat.java | 226 -----
.../seatunnel/flink/druid/sink/DruidSink.java | 88 --
.../flink/druid/source/DruidInputFormat.java | 257 ------
.../seatunnel/flink/druid/source/DruidSource.java | 172 ----
.../seatunnel/flink/druid/source/DruidSql.java | 114 ---
.../pom.xml | 59 --
.../flink/elasticsearch6/config/Config.java | 69 --
.../flink/elasticsearch6/sink/Elasticsearch6.java | 152 ----
.../sink/ElasticsearchOutputFormat.java | 138 ---
.../pom.xml | 58 --
.../flink/elasticsearch/config/Config.java | 64 --
.../flink/elasticsearch/sink/Elasticsearch.java | 147 ----
.../sink/ElasticsearchOutputFormat.java | 140 ---
.../seatunnel-connector-flink-fake/pom.xml | 52 --
.../org/apache/seatunnel/flink/fake/Config.java | 158 ----
.../seatunnel/flink/fake/source/FakeSource.java | 85 --
.../flink/fake/source/FakeSourceStream.java | 95 ---
.../seatunnel/flink/fake/source/MockSchema.java | 485 -----------
.../seatunnel-connector-flink-file/pom.xml | 66 --
.../flink/file/sink/CsvRowOutputFormat.java | 184 ----
.../apache/seatunnel/flink/file/sink/FileSink.java | 164 ----
.../flink/file/sink/JsonRowOutputFormat.java | 130 ---
.../seatunnel/flink/file/source/FileSource.java | 130 ---
.../flink/file/source/JsonRowInputFormat.java | 116 ---
.../flink/file/source/TextRowInputFormat.java | 93 --
.../seatunnel/fink/file/source/FileSourceTest.java | 97 ---
.../src/test/resources/JsonFile.text | 18 -
.../src/test/resources/TestFile.text | 19 -
.../src/test/resources/flink.streaming.json.conf | 46 -
.../src/test/resources/flink.streaming.text.conf | 45 -
.../seatunnel-connector-flink-http/pom.xml | 59 --
.../apache/seatunnel/flink/http/source/Http.java | 155 ----
.../flink/http/source/constant/Settings.java | 30 -
.../flink/http/source/util/HttpClientResult.java | 61 --
.../flink/http/source/util/HttpClientUtils.java | 318 -------
.../seatunnel-connector-flink-influxdb/pom.xml | 42 -
.../flink/influxdb/sink/InfluxDbOutputFormat.java | 109 ---
.../flink/influxdb/sink/InfluxDbSink.java | 96 ---
.../flink/influxdb/source/InfluxDbInputFormat.java | 215 -----
.../flink/influxdb/source/InfluxDbSource.java | 148 ----
.../flink/influxdb/source/InfluxDbSql.java | 105 ---
.../seatunnel-connector-flink-jdbc/pom.xml | 66 --
.../org/apache/seatunnel/flink/jdbc/Config.java | 108 ---
.../jdbc/input/DefaultTypeInformationMap.java | 73 --
.../flink/jdbc/input/HiveTypeInformationMap.java | 77 --
.../flink/jdbc/input/JdbcInputFormat.java | 198 -----
.../flink/jdbc/input/MysqlTypeInformationMap.java | 93 --
.../flink/jdbc/input/OracleTypeInformationMap.java | 64 --
.../jdbc/input/PostgresTypeInformationMap.java | 77 --
.../flink/jdbc/input/TypeInformationMap.java | 34 -
.../apache/seatunnel/flink/jdbc/sink/JdbcSink.java | 223 -----
.../seatunnel/flink/jdbc/source/JdbcSource.java | 257 ------
.../seatunnel-connector-flink-kafka/pom.xml | 50 --
.../seatunnel/flink/kafka/sink/KafkaSink.java | 99 ---
.../flink/kafka/source/KafkaTableStream.java | 188 -----
.../seatunnel-connector-flink-socket/pom.xml | 41 -
.../flink/socket/source/SocketStream.java | 82 --
.../seatunnel-connectors-spark/pom.xml | 107 ---
.../seatunnel-connector-spark-clickhouse/pom.xml | 56 --
.../org.apache.seatunnel.spark.BaseSparkSink | 19 -
.../apache/seatunnel/spark/clickhouse/Config.scala | 109 ---
.../spark/clickhouse/sink/Clickhouse.scala | 547 ------------
.../spark/clickhouse/sink/ClickhouseFile.scala | 327 -------
.../seatunnel/spark/clickhouse/sink/Table.scala | 123 ---
.../sink/filetransfer/FileTransfer.scala | 30 -
.../sink/filetransfer/RsyncFileTransfer.scala | 94 ---
.../sink/filetransfer/ScpFileTransfer.scala | 87 --
.../sink/filetransfer/TransferMethod.scala | 35 -
.../src/test/resources/sea.conf | 61 --
.../spark/clickhouse/sink/ClickhouseFileTest.scala | 66 --
.../seatunnel-connector-spark-console/pom.xml | 32 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../apache/seatunnel/spark/console/Config.scala | 60 --
.../seatunnel/spark/console/sink/Console.scala | 73 --
.../seatunnel-connector-spark-doris/pom.xml | 65 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../apache/seatunnel/spark/doris/sink/Config.scala | 39 -
.../apache/seatunnel/spark/doris/sink/Doris.scala | 105 ---
.../seatunnel/spark/doris/sink/DorisUtil.scala | 120 ---
.../pom.xml | 44 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel/spark/elasticsearch/Config.scala | 58 --
.../spark/elasticsearch/sink/Elasticsearch.scala | 83 --
.../spark/elasticsearch/source/Elasticsearch.scala | 75 --
.../seatunnel-connector-spark-email/pom.xml | 49 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org/apache/seatunnel/spark/email/Config.scala | 94 ---
.../seatunnel/spark/email/sink/DataLocator.scala | 201 -----
.../apache/seatunnel/spark/email/sink/Email.scala | 136 ---
.../spark/email/sink/ExcelFileSaver.scala | 23 -
.../apache/seatunnel/spark/email/sink/Util.scala | 62 --
.../seatunnel-connector-spark-fake/pom.xml | 39 -
.../org.apache.seatunnel.spark.BaseSparkSource | 19 -
.../apache/seatunnel/spark/fake/source/Fake.scala | 41 -
.../seatunnel/spark/fake/source/FakeStream.scala | 101 ---
.../seatunnel-connector-spark-feishu/pom.xml | 43 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/feishu/Config.scala | 50 --
.../seatunnel/spark/feishu/FeishuClient.scala | 163 ----
.../spark/feishu/source/FeishuSheet.scala | 66 --
.../seatunnel-connector-spark-file/pom.xml | 32 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/file/Config.scala | 40 -
.../apache/seatunnel/spark/file/sink/File.scala | 74 --
.../apache/seatunnel/spark/file/source/File.scala | 68 --
.../seatunnel-connector-spark-hbase/pom.xml | 62 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/hbase/Config.scala | 50 --
.../apache/seatunnel/spark/hbase/sink/Hbase.scala | 169 ----
.../seatunnel/spark/hbase/sink/HbaseSaveMode.scala | 24 -
.../seatunnel/spark/hbase/source/Hbase.scala | 54 --
.../seatunnel-connector-spark-hive/pom.xml | 32 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../apache/seatunnel/spark/hive/sink/Hive.scala | 66 --
.../apache/seatunnel/spark/hive/source/Hive.scala | 36 -
.../seatunnel-connector-spark-http/pom.xml | 50 --
.../apache/seatunnel/spark/http/source/Http.java | 140 ---
.../spark/http/source/constant/Settings.java | 30 -
.../spark/http/source/util/HttpClientResult.java | 73 --
.../spark/http/source/util/HttpClientUtils.java | 312 -------
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel-connector-spark-hudi/pom.xml | 44 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/hudi/Config.scala | 48 --
.../apache/seatunnel/spark/hudi/sink/Hudi.scala | 52 --
.../apache/seatunnel/spark/hudi/source/Hudi.scala | 45 -
.../seatunnel-connector-spark-iceberg/pom.xml | 50 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../apache/seatunnel/spark/iceberg/Config.scala | 43 -
.../seatunnel/spark/iceberg/sink/Iceberg.scala | 59 --
.../seatunnel/spark/iceberg/source/Iceberg.scala | 54 --
.../seatunnel-connector-spark-jdbc/pom.xml | 56 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../apache/seatunnel/spark/jdbc/sink/Jdbc.scala | 76 --
.../apache/seatunnel/spark/jdbc/source/Jdbc.scala | 70 --
.../spark/jdbc/source/util/HiveDialect.scala | 34 -
.../datasources/jdbc2/DefaultSource.scala | 110 ---
.../execution/datasources/jdbc2/JDBCOptions.scala | 246 ------
.../datasources/jdbc2/JDBCPartition.scala | 303 -------
.../datasources/jdbc2/JDBCPartitioningInfo.scala | 285 -------
.../execution/datasources/jdbc2/JDBCSaveMode.scala | 25 -
.../execution/datasources/jdbc2/JdbcUtils.scala | 939 ---------------------
.../seatunnel-connector-spark-kafka/pom.xml | 46 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../apache/seatunnel/spark/kafka/sink/Kafka.scala | 109 ---
.../spark/kafka/sink/KafkaProducerUtil.scala | 44 -
.../seatunnel/spark/kafka/source/KafkaStream.scala | 127 ---
.../seatunnel-connector-spark-kudu/pom.xml | 48 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../apache/seatunnel/spark/kudu/sink/Kudu.scala | 58 --
.../apache/seatunnel/spark/kudu/source/Kudu.scala | 45 -
.../seatunnel-connector-spark-mongodb/pom.xml | 40 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel/spark/mongodb/sink/MongoDB.scala | 58 --
.../seatunnel/spark/mongodb/source/MongoDB.scala | 72 --
.../seatunnel-connector-spark-neo4j/pom.xml | 50 --
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel/spark/neo4j/source/Neo4j.scala | 58 --
.../seatunnel-connector-spark-phoenix/pom.xml | 62 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../scala/org/apache/phoenix/spark/CsUtil.scala | 35 -
.../apache/phoenix/spark/DataFrameFunctions2.scala | 86 --
.../org/apache/phoenix/spark/PhoenixRDD2.scala | 53 --
.../phoenix/spark/SparkSqlContextFunctions2.scala | 46 -
.../org/apache/phoenix/spark/ZkConnectUtil.scala | 35 -
.../org/apache/phoenix/spark/sparkExtend.scala | 33 -
.../seatunnel/spark/phoenix/sink/Phoenix.scala | 80 --
.../seatunnel/spark/phoenix/source/Phoenix.scala | 78 --
.../seatunnel-connector-spark-redis/pom.xml | 46 -
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel/spark/redis/common/Constants.scala | 47 --
.../spark/redis/common/RedisDataType.scala | 28 -
.../seatunnel/spark/redis/common/RedisUtil.scala | 44 -
.../common/SelfAchievedRedisProxyConfig.scala | 31 -
.../apache/seatunnel/spark/redis/sink/Redis.scala | 110 ---
.../seatunnel/spark/redis/source/Redis.scala | 124 ---
.../seatunnel-connector-spark-socket/pom.xml | 39 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/socket/Config.scala | 44 -
.../spark/socket/source/SocketStream.scala | 54 --
.../seatunnel-connector-spark-tidb/pom.xml | 55 --
.../org.apache.seatunnel.spark.BaseSparkSink | 18 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../org/apache/seatunnel/spark/tidb/Config.scala | 59 --
.../apache/seatunnel/spark/tidb/sink/Tidb.scala | 65 --
.../apache/seatunnel/spark/tidb/source/Tidb.scala | 42 -
.../seatunnel-connector-spark-webhook/pom.xml | 39 -
.../org.apache.seatunnel.spark.BaseSparkSource | 18 -
.../seatunnel/spark/webhook/source/HttpData.scala | 26 -
.../spark/webhook/source/HttpPushServlet.scala | 37 -
.../spark/webhook/source/JettyServer.scala | 59 --
.../spark/webhook/source/WebhookStream.scala | 60 --
seatunnel-core/pom.xml | 3 -
seatunnel-core/seatunnel-core-flink-sql/README.md | 40 -
seatunnel-core/seatunnel-core-flink-sql/pom.xml | 107 ---
.../src/main/bin/start-seatunnel-sql.sh | 74 --
.../core/sql/FlinkEnvParameterParser.java | 45 -
.../apache/seatunnel/core/sql/FlinkSqlStarter.java | 76 --
.../apache/seatunnel/core/sql/SeatunnelSql.java | 48 --
.../core/sql/classloader/CustomClassLoader.java | 49 --
.../apache/seatunnel/core/sql/job/Executor.java | 218 -----
.../org/apache/seatunnel/core/sql/job/JobInfo.java | 46 -
.../core/sql/splitter/SqlStatementSplitter.java | 87 --
.../core/sql/FlinkEnvParameterParserTest.java | 37 -
.../core/sql/SqlVariableSubstitutionTest.java | 52 --
.../sql/classloader/CustomClassLoaderTest.java | 35 -
.../seatunnel/core/sql/job/ExecutorTest.java | 44 -
.../apache/seatunnel/core/sql/job/JobInfoTest.java | 34 -
.../sql/splitter/SqlStatementSplitterTest.java | 46 -
.../src/test/resources/flink.sql.conf.template | 49 --
seatunnel-core/seatunnel-core-flink/pom.xml | 228 -----
.../src/main/bin/start-seatunnel-flink.sh | 84 --
.../src/main/docker/Dockerfile | 37 -
.../core/flink/FlinkEnvParameterParser.java | 60 --
.../apache/seatunnel/core/flink/FlinkStarter.java | 84 --
.../seatunnel/core/flink/SeatunnelFlink.java | 37 -
.../core/flink/args/FlinkCommandArgs.java | 74 --
.../flink/command/FlinkApiConfValidateCommand.java | 50 --
.../flink/command/FlinkApiTaskExecuteCommand.java | 120 ---
.../core/flink/command/FlinkCommandBuilder.java | 33 -
.../core/flink/config/FlinkApiConfigChecker.java | 44 -
.../core/flink/config/FlinkExecutionContext.java | 108 ---
.../seatunnel/core/flink/config/FlinkJobType.java | 34 -
.../seatunnel/core/flink/config/FlinkRunMode.java | 45 -
.../core/flink/FlinkEnvParameterParserTest.java | 47 --
.../seatunnel/core/flink/FlinkStarterTest.java | 49 --
.../core/flink/args/FlinkCommandArgsTest.java | 39 -
.../flink/command/FlinkTaskExecuteCommandTest.java | 64 --
.../core/flink/utils/CommandLineUtilsTest.java | 49 --
.../src/test/resources/app.conf | 50 --
.../src/test/resources/sql.conf | 49 --
seatunnel-core/seatunnel-core-spark/pom.xml | 260 ------
.../src/main/bin/start-seatunnel-spark.sh | 73 --
.../src/main/docker/Dockerfile | 37 -
.../seatunnel/core/spark/SeatunnelSpark.java | 35 -
.../apache/seatunnel/core/spark/SparkStarter.java | 385 ---------
.../core/spark/args/SparkCommandArgs.java | 62 --
.../core/spark/command/SparkCommandBuilder.java | 35 -
.../spark/command/SparkConfValidateCommand.java | 50 --
.../spark/command/SparkTaskExecuteCommand.java | 75 --
.../core/spark/config/SparkApiConfigChecker.java | 44 -
.../core/spark/config/SparkExecutionContext.java | 107 ---
.../seatunnel/core/spark/SparkStarterTest.java | 40 -
.../core/spark/args/SparkCommandArgsTest.java | 40 -
.../core/spark/utils/CommandLineUtilsTest.java | 44 -
.../src/test/resources/spark_application.conf | 66 --
seatunnel-dist/pom.xml | 313 -------
seatunnel-dist/release-docs/LICENSE | 67 +-
seatunnel-dist/release-docs/NOTICE | 22 -
.../release-docs/licenses/LICENSE-akka.txt | 20 -
.../release-docs/licenses/LICENSE-grizzled.txt | 14 -
.../release-docs/licenses/LICENSE-javassist.txt | 141 ----
.../release-docs/licenses/LICENSE-kryo.txt | 8 -
.../release-docs/licenses/LICENSE-minlog.txt | 13 -
.../release-docs/licenses/LICENSE-reactive.txt | 8 -
.../release-docs/licenses/LICENSE-scopt.txt | 21 -
.../src/main/assembly/assembly-bin-ci.xml | 54 --
seatunnel-dist/src/main/assembly/assembly-bin.xml | 21 -
seatunnel-e2e/pom.xml | 3 -
seatunnel-e2e/seatunnel-flink-e2e/pom.xml | 47 --
.../seatunnel-connector-flink-assert-e2e/pom.xml | 53 --
.../e2e/flink/assertion/FakeSourceToAssertIT.java | 35 -
.../resources/assertion/fakesource_to_assert.conf | 88 --
.../pom.xml | 53 --
.../flink/clickhouse/FakeSourceToClickhouseIT.java | 123 ---
.../clickhouse/fakesource_to_clickhouse.conf | 60 --
.../seatunnel-connector-flink-e2e-base/pom.xml | 55 --
.../apache/seatunnel/e2e/flink/FlinkContainer.java | 59 --
.../seatunnel-connector-flink-fake-e2e/pom.xml | 53 --
.../e2e/flink/fake/FakeSourceToConsoleIT.java | 35 -
.../test/resources/fake/fakesource_to_console.conf | 45 -
.../seatunnel-connector-flink-file-e2e/pom.xml | 53 --
.../e2e/flink/file/FakeSourceToFileIT.java | 35 -
.../test/resources/file/fakesource_to_file.conf | 56 --
.../seatunnel-connector-flink-http-e2e/pom.xml | 53 --
.../e2e/flink/http/HttpSourceToConsoleIT.java | 35 -
.../test/resources/http/httpsource_to_console.conf | 50 --
seatunnel-e2e/seatunnel-flink-sql-e2e/pom.xml | 42 -
.../setunnel-connector-flink-sql-e2e-base/pom.xml | 56 --
.../seatunnel/e2e/flink/sql/FlinkContainer.java | 70 --
.../setunnel-connector-flink-sql-fake-e2e/pom.xml | 40 -
.../e2e/flink/sql/fake/DatagenToConsoleIT.java | 36 -
.../src/test/resources/fake/flink.sql.conf | 50 --
seatunnel-e2e/seatunnel-spark-e2e/pom.xml | 45 -
.../seatunnel-connector-spark-e2e-base/pom.xml | 56 --
.../apache/seatunnel/e2e/spark/SparkContainer.java | 58 --
.../seatunnel-connector-spark-fake-e2e/pom.xml | 53 --
.../e2e/spark/fake/FakeSourceToConsoleIT.java | 39 -
.../test/resources/fake/fakesource_to_console.conf | 60 --
.../seatunnel-connector-spark-http-e2e/pom.xml | 51 --
.../e2e/spark/http/HttpSourceToConsoleIT.java | 39 -
.../test/resources/http/httpsource_to_console.conf | 73 --
.../seatunnel-connector-spark-jdbc-e2e/pom.xml | 82 --
.../e2e/spark/jdbc/FakeSourceToJdbcIT.java | 104 ---
.../e2e/spark/jdbc/JdbcSourceToConsoleIT.java | 114 ---
.../test/resources/jdbc/fakesource_to_jdbc.conf | 60 --
.../test/resources/jdbc/jdbcsource_to_console.conf | 53 --
seatunnel-examples/pom.xml | 3 -
.../seatunnel-flink-examples/pom.xml | 110 ---
.../seatunnel/example/flink/LocalFlinkExample.java | 51 --
.../main/resources/examples/fake_to_console.conf | 53 --
.../src/main/resources/log4j.properties | 22 -
.../seatunnel-flink-sql-examples/pom.xml | 99 ---
.../seatunnel/example/flink/LocalSqlExample.java | 48 --
.../resources/examples/flink.sql.conf.template | 49 --
.../src/main/resources/log4j.properties | 22 -
.../seatunnel-spark-examples/pom.xml | 103 ---
.../seatunnel/example/spark/LocalSparkExample.java | 52 --
.../spark/LocalSparkToClickHouseExample.java | 52 --
.../resources/examples/spark.batch.clickhouse.conf | 47 --
.../src/main/resources/examples/spark.batch.conf | 73 --
.../src/main/resources/log4j.properties | 22 -
tools/dependencies/known-dependencies.txt | 55 --
450 files changed, 5 insertions(+), 35179 deletions(-)
delete mode 100644 deploy/docker/flink/README.md
delete mode 100644 deploy/docker/flink/config/application.conf
delete mode 100644 deploy/docker/flink/config/flink-conf.yaml
delete mode 100644 deploy/docker/flink/docker-compose.yaml
delete mode 100644 deploy/docker/spark/.env
delete mode 100644 deploy/docker/spark/README.md
delete mode 100644 deploy/docker/spark/config/application.conf
delete mode 100644 deploy/docker/spark/docker-compose.yaml
delete mode 100644 deploy/helm/seatunnel_flink/Chart.yaml
delete mode 100644 deploy/helm/seatunnel_flink/README.md
delete mode 100644 deploy/helm/seatunnel_flink/requirements.yaml
delete mode 100644 deploy/helm/seatunnel_flink/templates/flink-conf.yaml
delete mode 100644 deploy/helm/seatunnel_flink/templates/seatunnel-flink.yaml
delete mode 100644 deploy/helm/seatunnel_flink/values.yaml
delete mode 100644 deploy/helm/seatunnel_spark/Chart.yaml
delete mode 100644 deploy/helm/seatunnel_spark/README.md
delete mode 100644 deploy/helm/seatunnel_spark/templates/seatunnel-spark.yaml
delete mode 100644 deploy/helm/seatunnel_spark/templates/spark-conf.yaml
delete mode 100644 deploy/helm/seatunnel_spark/values.yaml
delete mode 100644 docs/en/connector/flink-sql/ElasticSearch.md
delete mode 100644 docs/en/connector/flink-sql/Jdbc.md
delete mode 100644 docs/en/connector/flink-sql/Kafka.md
delete mode 100644 docs/en/connector/flink-sql/usage.md
delete mode 100644 docs/en/connector/sink/Assert.md
delete mode 100644 docs/en/connector/sink/Clickhouse.md
delete mode 100644 docs/en/connector/sink/ClickhouseFile.md
delete mode 100644 docs/en/connector/sink/Console.mdx
delete mode 100644 docs/en/connector/sink/Doris.mdx
delete mode 100644 docs/en/connector/sink/Druid.md
delete mode 100644 docs/en/connector/sink/Elasticsearch.mdx
delete mode 100644 docs/en/connector/sink/Email.md
delete mode 100644 docs/en/connector/sink/File.mdx
delete mode 100644 docs/en/connector/sink/Hbase.md
delete mode 100644 docs/en/connector/sink/Hive.md
delete mode 100644 docs/en/connector/sink/Hudi.md
delete mode 100644 docs/en/connector/sink/Iceberg.md
delete mode 100644 docs/en/connector/sink/InfluxDB.md
delete mode 100644 docs/en/connector/sink/Jdbc.mdx
delete mode 100644 docs/en/connector/sink/Kafka.mdx
delete mode 100644 docs/en/connector/sink/Kudu.md
delete mode 100644 docs/en/connector/sink/MongoDB.md
delete mode 100644 docs/en/connector/sink/Phoenix.md
delete mode 100644 docs/en/connector/sink/Redis.md
delete mode 100644 docs/en/connector/sink/Tidb.md
delete mode 100644 docs/en/connector/sink/common-options.md
delete mode 100644 docs/en/connector/source/Druid.md
delete mode 100644 docs/en/connector/source/Elasticsearch.md
delete mode 100644 docs/en/connector/source/Fake.mdx
delete mode 100644 docs/en/connector/source/FeishuSheet.md
delete mode 100644 docs/en/connector/source/File.mdx
delete mode 100644 docs/en/connector/source/Hbase.md
delete mode 100644 docs/en/connector/source/Hive.md
delete mode 100644 docs/en/connector/source/Http.md
delete mode 100644 docs/en/connector/source/Hudi.md
delete mode 100644 docs/en/connector/source/Iceberg.md
delete mode 100644 docs/en/connector/source/InfluxDB.md
delete mode 100644 docs/en/connector/source/Jdbc.mdx
delete mode 100644 docs/en/connector/source/Kafka.mdx
delete mode 100644 docs/en/connector/source/Kudu.md
delete mode 100644 docs/en/connector/source/MongoDB.md
delete mode 100644 docs/en/connector/source/Phoenix.md
delete mode 100644 docs/en/connector/source/Redis.md
delete mode 100644 docs/en/connector/source/Socket.mdx
delete mode 100644 docs/en/connector/source/Tidb.md
delete mode 100644 docs/en/connector/source/Webhook.md
delete mode 100644 docs/en/connector/source/common-options.mdx
delete mode 100644 docs/en/connector/source/neo4j.md
delete mode 100644 docs/en/start/docker.md
delete mode 100644 docs/en/start/kubernetes.mdx
delete mode 100644 docs/en/start/local.mdx
delete mode 100644 seatunnel-connectors/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-6/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-7/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-jdbc/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-kafka/pom.xml
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink-sql/pom.xml
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/AssertExecutor.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/rule/AssertFieldRule.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParser.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/sink/AssertSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/test/java/org/apache/seatunnel/flink/assertion/AssertExecutorTest.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/test/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParserTest.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/ConfigKey.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/ClickhouseFileCopyMethod.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/DistributedEngine.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/IntHolder.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/Shard.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/ShardMetadata.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseBatchSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileBatchSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ClickhouseBatchStatement.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ClickhouseClient.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ShardRouter.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/ClickhouseTable.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/FileTransfer.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/ScpFileTransfer.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/ArrayInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/BigDecimalInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/ClickhouseFieldInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DateInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DateTimeInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DoubleInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/FloatInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/IntInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/LongInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/StringInjectFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/test/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileTest.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/console/sink/ConsoleSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisSinkFunction.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisStreamLoad.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/sink/DruidOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/sink/DruidSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidInputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidSource.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidSql.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/config/Config.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/sink/Elasticsearch6.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/sink/ElasticsearchOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/config/Config.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/sink/Elasticsearch.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/sink/ElasticsearchOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/Config.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/FakeSource.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/FakeSourceStream.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/MockSchema.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/CsvRowOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/JsonRowOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/FileSource.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/JsonRowInputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/TextRowInputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/java/org/apache/seatunnel/fink/file/source/FileSourceTest.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/JsonFile.text
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/TestFile.text
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.json.conf
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.text.conf
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/Http.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/constant/Settings.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientResult.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/sink/InfluxDbOutputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/sink/InfluxDbSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbInputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbSource.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbSql.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/Config.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/DefaultTypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/HiveTypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/JdbcInputFormat.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/MysqlTypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/OracleTypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/PostgresTypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/TypeInformationMap.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/sink/JdbcSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/kafka/sink/KafkaSink.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/kafka/source/KafkaTableStream.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/socket/source/SocketStream.java
delete mode 100644 seatunnel-connectors/seatunnel-connectors-spark/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/Clickhouse.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/ClickhouseFile.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/Table.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/FileTransfer.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/RsyncFileTransfer.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/ScpFileTransfer.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/TransferMethod.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/test/resources/sea.conf
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/test/scala/org/apache/seatunnel/spark/clickhouse/sink/ClickhouseFileTest.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/console/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/console/sink/Console.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/Doris.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/DorisUtil.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/sink/Elasticsearch.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/source/Elasticsearch.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/DataLocator.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/Email.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/ExcelFileSaver.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/Util.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/fake/source/Fake.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/fake/source/FakeStream.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/FeishuClient.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/source/FeishuSheet.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/sink/File.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/source/File.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/sink/Hbase.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/sink/HbaseSaveMode.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/source/Hbase.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/source/Hive.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/Http.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/constant/Settings.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientResult.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/sink/Hudi.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/sink/Iceberg.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/source/Iceberg.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/sink/Jdbc.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/source/Jdbc.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/source/util/HiveDialect.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/sink/Kafka.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/sink/KafkaProducerUtil.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/source/KafkaStream.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/kudu/sink/Kudu.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/kudu/source/Kudu.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/mongodb/sink/MongoDB.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/mongodb/source/MongoDB.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/neo4j/source/Neo4j.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/phoenix/sink/Phoenix.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/phoenix/source/Phoenix.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/Constants.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/RedisDataType.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/RedisUtil.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/SelfAchievedRedisProxyConfig.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/source/Redis.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/socket/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/socket/source/SocketStream.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/Config.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/sink/Tidb.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/source/Tidb.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/HttpData.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/HttpPushServlet.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/JettyServer.scala
delete mode 100644
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/WebhookStream.scala
delete mode 100644 seatunnel-core/seatunnel-core-flink-sql/README.md
delete mode 100644 seatunnel-core/seatunnel-core-flink-sql/pom.xml
delete mode 100755
seatunnel-core/seatunnel-core-flink-sql/src/main/bin/start-seatunnel-sql.sh
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParser.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/FlinkSqlStarter.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/SeatunnelSql.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoader.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/JobInfo.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/splitter/SqlStatementSplitter.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParserTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/SqlVariableSubstitutionTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoaderTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/job/ExecutorTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/job/JobInfoTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/splitter/SqlStatementSplitterTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink-sql/src/test/resources/flink.sql.conf.template
delete mode 100644 seatunnel-core/seatunnel-core-flink/pom.xml
delete mode 100755
seatunnel-core/seatunnel-core-flink/src/main/bin/start-seatunnel-flink.sh
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/docker/Dockerfile
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParser.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/FlinkStarter.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/SeatunnelFlink.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/args/FlinkCommandArgs.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiConfValidateCommand.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkCommandBuilder.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkApiConfigChecker.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkExecutionContext.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkJobType.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkRunMode.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParserTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/FlinkStarterTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/args/FlinkCommandArgsTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommandTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/utils/CommandLineUtilsTest.java
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/resources/app.conf
delete mode 100644
seatunnel-core/seatunnel-core-flink/src/test/resources/sql.conf
delete mode 100644 seatunnel-core/seatunnel-core-spark/pom.xml
delete mode 100755
seatunnel-core/seatunnel-core-spark/src/main/bin/start-seatunnel-spark.sh
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/docker/Dockerfile
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SeatunnelSpark.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/args/SparkCommandArgs.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkCommandBuilder.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkConfValidateCommand.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkTaskExecuteCommand.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/config/SparkApiConfigChecker.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/config/SparkExecutionContext.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/SparkStarterTest.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/args/SparkCommandArgsTest.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/utils/CommandLineUtilsTest.java
delete mode 100644
seatunnel-core/seatunnel-core-spark/src/test/resources/spark_application.conf
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-akka.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-grizzled.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-javassist.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-kryo.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-minlog.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-reactive.txt
delete mode 100644 seatunnel-dist/release-docs/licenses/LICENSE-scopt.txt
delete mode 100644 seatunnel-e2e/seatunnel-flink-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/src/test/java/org/apache/seatunnel/e2e/flink/assertion/FakeSourceToAssertIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/src/test/resources/assertion/fakesource_to_assert.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/src/test/java/org/apache/seatunnel/e2e/flink/clickhouse/FakeSourceToClickhouseIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/src/test/resources/clickhouse/fakesource_to_clickhouse.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-e2e-base/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/src/test/java/org/apache/seatunnel/e2e/flink/fake/FakeSourceToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/src/test/resources/fake/fakesource_to_console.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/src/test/java/org/apache/seatunnel/e2e/flink/file/FakeSourceToFileIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/src/test/resources/file/fakesource_to_file.conf
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/src/test/java/org/apache/seatunnel/e2e/flink/http/HttpSourceToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/src/test/resources/http/httpsource_to_console.conf
delete mode 100644 seatunnel-e2e/seatunnel-flink-sql-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-e2e-base/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/sql/FlinkContainer.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/src/test/java/org/apache/seatunnel/e2e/flink/sql/fake/DatagenToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/src/test/resources/fake/flink.sql.conf
delete mode 100644 seatunnel-e2e/seatunnel-spark-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-e2e-base/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-e2e-base/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/src/test/java/org/apache/seatunnel/e2e/spark/fake/FakeSourceToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/src/test/resources/fake/fakesource_to_console.conf
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/src/test/java/org/apache/seatunnel/e2e/spark/http/HttpSourceToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/src/test/resources/http/httpsource_to_console.conf
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/java/org/apache/seatunnel/e2e/spark/jdbc/FakeSourceToJdbcIT.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/java/org/apache/seatunnel/e2e/spark/jdbc/JdbcSourceToConsoleIT.java
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/resources/jdbc/fakesource_to_jdbc.conf
delete mode 100644
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/resources/jdbc/jdbcsource_to_console.conf
delete mode 100644 seatunnel-examples/seatunnel-flink-examples/pom.xml
delete mode 100644
seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java
delete mode 100644
seatunnel-examples/seatunnel-flink-examples/src/main/resources/examples/fake_to_console.conf
delete mode 100644
seatunnel-examples/seatunnel-flink-examples/src/main/resources/log4j.properties
delete mode 100644 seatunnel-examples/seatunnel-flink-sql-examples/pom.xml
delete mode 100644
seatunnel-examples/seatunnel-flink-sql-examples/src/main/java/org/apache/seatunnel/example/flink/LocalSqlExample.java
delete mode 100644
seatunnel-examples/seatunnel-flink-sql-examples/src/main/resources/examples/flink.sql.conf.template
delete mode 100644
seatunnel-examples/seatunnel-flink-sql-examples/src/main/resources/log4j.properties
delete mode 100644 seatunnel-examples/seatunnel-spark-examples/pom.xml
delete mode 100644
seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java
delete mode 100644
seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkToClickHouseExample.java
delete mode 100644
seatunnel-examples/seatunnel-spark-examples/src/main/resources/examples/spark.batch.clickhouse.conf
delete mode 100644
seatunnel-examples/seatunnel-spark-examples/src/main/resources/examples/spark.batch.conf
delete mode 100644
seatunnel-examples/seatunnel-spark-examples/src/main/resources/log4j.properties
