You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/06/30 08:40:11 UTC
[incubator-seatunnel] branch api-draft updated (6a492d79b -> 10ac17e8c)
This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a change to branch api-draft
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 6a492d79b Update Clickhouse.md (#2096)
add 7d92e8c8f [Feature][Doc] Add Config file introduce. (#1740)
add 2fb1797b7 [Feature][core] Refractor seatunnel-core module (#1775)
add 64f513e82 [Feature][seatunnel-transforms] Add Uuid transform for spark (#1770)
add 6b42a6b50 [Improvement][connector-spark-iceberg] Refactored config arguments and defaults (#1782)
add 2b650981b [Refactor][seatunnel-core-flink] refactor flink-sql module (#1783)
add bf6893f18 [JavaDoc][seatunnel-core-base] correct java doc (#1790)
add c5291cd4f [Bug] [SparkStarter] when spark extraJavaOptions is null, an exception parameter will be generated, resulting in submission failure (#1793)
add bb067b403 [Feature][Seatunnel-core] format usage help output (#1788)
add 74e8dc1cc [Bugfix][seatunnel-core-flin/spark] fix shell variable unset error (#1796)
add 8d02ab4b0 [Bug] [Spark] SeaTunnel on spark standalone cluster “plugins.tar.gz” decompress error. #1733 (#1757)
add 1351ee9e2 [Improve][UT] optimize ut logic (#1803)
add ee6a9870b [Feature][Seatunnel-core-fline] Support Flink dynamic configurations (#1800)
add 1a368dc04 [Bug] [flink-connector-jdbc]change jdbc Source connector to get fields from jdbc meta data and support oracle database (#1781)
add d50fe1ed9 [Feature][Connector]support flink-connecor-http (#1798)
add ea40a7ff6 [Bug] [Connector] Clickhouse sink can not work correctly when use multiple hosts (#1808) (#1809)
add ef5d1f2c8 [Improve][IT]Adjust it test case path (#1817)
add 63103c47b [Bug] [seatunnel-core-spark] plugin jars can't be added correctly in SparkStarter (#1819)
add 13846f45d [Bugfix][seatunnel-core-flink] fix flink sql conf parse exception (#1815)
add 56f68afc2 [Feature][flink-connector-jdbc] add pre sql and post sql #1789 (#1791)
add 4cc20a4be Add flink sql e2e module (#1828)
add 3417c04f4 [hotfix][connector-fake][docs] Updated description (#1823)
add 139a0aacd [hotfix][connector-sink-console][docs] Update example limit description (#1811)
add 9b113e548 [Bugfix][seatunnel-core-flink-sql] fix configuration parsing from sql script (#1825)
add fcadfebcc [bug][flink-connector-jdbc]supplement mysql jdbc all type information (#1816)
add a23fa528b [fix bug] the Decimal(P, S) cast to String ClassCastException (#1810)
add bf62a6796 [Improve][UT] add ut for Flink SQL module (#1836)
add e86963465 [hotfix][connector-file] Corrected description - removed reference to Doris table (#1838)
add cc457f0e5 Add a step of Install JetBrains IDEA Lombok Plugin (#1841)
add 63befd5cb [Feature][flink-transform] add transform for register user define function (#1826)
add e35b65a34 [Bug][Starter] Fix variables cannot be set in flink mode (#1854)
add 53e7a8ce9 [Feature][Flink-SQL] Support connector dynamic loading for FlinkSQL job and add Flink SQL jdbc connector (#1850)
add 2786a5881 [hotfix][docs] add Flink version limit less then 1.14.x . (#1860)
add 34b2c22e4 [Improvement][connector-spark-kafka] Refactored config arguments and defaults (#1862)
add a0744de83 [Improvement][connector-spark-redis] Host and port are optional so removed existance check (#1857)
add 6db9e970d [hotfix][core] check plugin type before execute (#1866)
add 51d9af9b4 Use @AutoService to generate SPI file (#1873)
add 295d08b4f [CodeStyle] remove unnecessary semicolon (#1883)
add 91ddc2e83 [Feature][seatunnel-connector-flink-fake] Support FakeSourceStream to mock data. (#1880)
add 6cade31e5 [Feature][Flink-SQL-connector] add flink sql connector kafka and docs (#1878)
add 2ca38ac40 [Doc] [Improve] Update contribute guide about plugin mapping. (#1893)
add f7ecacb98 [Bug] [test] Auto close FileSource (#1634)
add 690adedbd [hotfix] change flink batch config source to FakeSource (#1906)
add 15f41bff0 fix: flink core cannot check source config.[bug] (#1909)
add d2455864c [Feature][Flink-SQL-connector] add flink sql connector elasticsearch 6&7 and docs (#1923)
add 5b714f0c8 [Feature][e2e] Use seatunnel script to submit job in e2e (#1937)
add 5c28ac5ac support read hive by jdbc (#1926)
add 8882f041c The toreactstream is converted to the changlogstream method. Support update, delete message. (#1895)
add 5057448c9 [Feature] [clickhouse| ClickhouseFile support ReplicatedMergeTree (#1911)
add 97cc0d888 [Feature]Use hive-sink to save table as ORCFileFormat (#1929) (#1956)
add fb671b77f Revert "The toreactstream is converted to the changlogstream method. Support update, delete message. (#1895)" (#1972)
add 76c2cb37f [Feature][Sink] custom redis expire time (#1953) (#1970)
add 7e1c2fe22 [fix bug] When use TiDB, Spark JDBC update mode, Error "The isolation level ‘READ-UNCOMMITTED’ is not supported. Set tidb_skip_isolation_level_check=1 to skip this error" (#1975)
add 167e62c3b [Core] [Fix] add plugin mapping ignore case (#1979)
add 351713d63 [Improve]Use Jackson replace Fastjson (#1971)
add e619660a4 [Core] [Fix] fix shell can't show help message (#1982)
add 9ffa678c8 [Bug][build] Fix build failed (#1980)
add 14e4d2425 [Improvement][connector-spark-tidb] Refactored config parameters (#1983)
add 7a1a7e31f [Spark] Use higher version of the libthrift dependency (#1994)
add 4900c343e docs error (#1996)
add aaecca8f7 [Bug][seatunnel-core-flink] Updated FlinkRunMode enum to get the proper help message for run modes. (#2008)
add 8aa604034 a more understandable code,and code warning will disappear (#2005)
add e93fdf74b fix same source and sink registerplugin librarycache errpr (#2015)
add b663e5a35 [Doc][Transform] Add uuid, udf, replace transform to doc (#2016)
add 581b1e1d5 [Feature][Connector]add AssertSink connector (#2022)
add d64c1fa31 Add include upper bound (<=) (#2033)
add 4a6e1a2b1 [Jackson] [Core] fix jackson type convert error (#2031)
add 14e606611 [Doc] update seatunnel doc on kubernetes (#2035)
add a87889753 Improve CI jobs to reduce waiting time (#2049)
add 990ee8957 [Feature][Transform] data quality for null data rate (#1978)
add c83a02b6b [Feature][Doc] Add Flink SQL module to website. #2021 (#2056)
add 8737474a5 [Feat][UI] Increase the basic configuration of the front-end project. (#2075)
add 858c5a853 Support Rsync to transfer clickhouse data file (#2074)
add c74a16701 [Feat][UI] Add vue basic configuration. (#2087)
add d265597c6 merge dev to api-draft
add 736ac01c8 [API-DRAFT] [MERGE] fix merge error
add 3c0e98464 [API-DRAFT] [MERGE] fix merge error
add 10ac17e8c Merge remote-tracking branch 'origin/api-draft' into api-draft
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
config/flink.batch.conf.template | 8 +-
config/flink.sql.conf.template | 2 +-
docs/en/command/usage.mdx | 2 +
docs/en/connector/flink-sql/ElasticSearch.md | 48 +
docs/en/connector/flink-sql/Jdbc.md | 65 +
docs/en/connector/flink-sql/Kafka.md | 74 +
docs/en/connector/flink-sql/usage.md | 275 ++
docs/en/connector/sink/Assert.md | 3 +-
docs/en/connector/sink/Console.mdx | 2 +-
docs/en/connector/sink/Jdbc.mdx | 41 +-
docs/en/connector/sink/Redis.md | 5 +
docs/en/connector/source/Fake.mdx | 76 +-
docs/en/connector/source/File.mdx | 4 +-
docs/en/connector/source/Http.md | 2 +-
docs/en/connector/source/Socket.mdx | 8 +-
docs/en/contribution/contribute-plugin.md | 41 +-
docs/en/contribution/setup.md | 5 +
docs/en/start/kubernetes.mdx | 38 +-
docs/en/start/local.mdx | 4 +-
docs/en/transform/nullRate.md | 67 +
docs/en/transform/udf.md | 42 +
docs/sidebars.js | 21 +
plugin-mapping.properties | 1 +
pom.xml | 82 +-
.../apache/seatunnel/flink/util/SchemaUtil.java | 42 +-
seatunnel-common/pom.xml | 9 +-
.../apache/seatunnel/common/utils/JsonUtils.java | 5 +
.../common/config/TypesafeConfigUtilsTest.java | 5 +-
seatunnel-connectors/pom.xml | 2 +
.../seatunnel-connectors-flink-dist/pom.xml | 12 +
.../seatunnel-connectors-flink-sql-dist/pom.xml | 76 +
.../flink-sql-connector-elasticsearch-6}/pom.xml | 30 +-
.../flink-sql-connector-elasticsearch-7}/pom.xml | 30 +-
.../flink-sql-connector-jdbc}/pom.xml | 33 +-
.../flink-sql-connector-kafka}/pom.xml | 16 +-
.../{ => seatunnel-connectors-flink-sql}/pom.xml | 35 +-
.../seatunnel-connectors-flink/pom.xml | 2 +
.../pom.xml | 2 +-
.../seatunnel/flink/assertion}/AssertExecutor.java | 45 +-
.../flink}/assertion/rule/AssertFieldRule.java | 7 +-
.../flink}/assertion/rule/AssertRuleParser.java | 57 +-
.../seatunnel/flink/assertion/sink/AssertSink.java | 113 +
.../flink/assertion/AssertExecutorTest.java | 28 +-
.../flink/assertion/rule/AssertRuleParserTest.java | 12 +-
.../seatunnel-connector-flink-clickhouse/pom.xml | 6 +
.../flink/clickhouse/sink/ClickhouseBatchSink.java | 3 +
.../clickhouse/sink/ClickhouseFileBatchSink.java | 8 +-
.../clickhouse/sink/client/ClickhouseClient.java | 25 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 19 -
.../flink/clickhouse/sink/ClickhouseFileTest.java | 60 +
.../seatunnel/flink/console/sink/ConsoleSink.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../seatunnel/flink/doris/sink/DorisSink.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../seatunnel/flink/druid/sink/DruidSink.java | 3 +
.../seatunnel/flink/druid/source/DruidSource.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../flink/elasticsearch6/sink/Elasticsearch6.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../flink/elasticsearch/sink/Elasticsearch.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../seatunnel-connector-flink-fake/pom.xml | 4 +
.../org/apache/seatunnel/flink/fake/Config.java | 158 +
.../seatunnel/flink/fake/source/FakeSource.java | 40 +-
.../flink/fake/source/FakeSourceStream.java | 36 +-
.../seatunnel/flink/fake/source/MockSchema.java | 492 ++++
.../org.apache.seatunnel.flink.BaseFlinkSource | 19 -
.../apache/seatunnel/flink/file/sink/FileSink.java | 3 +
.../flink/file/source/JsonRowInputFormat.java | 27 +-
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../seatunnel/fink/file/source/FileSourceTest.java | 20 +-
.../seatunnel-connector-flink-http}/pom.xml | 27 +-
.../apache/seatunnel/flink}/http/source/Http.java | 107 +-
.../flink}/http/source/constant/Settings.java | 2 +-
.../flink}/http/source/util/HttpClientResult.java | 14 +-
.../flink}/http/source/util/HttpClientUtils.java | 14 +-
.../flink/influxdb/sink/InfluxDbSink.java | 3 +
.../flink/influxdb/source/InfluxDbSource.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../org/apache/seatunnel/flink/jdbc/Config.java | 14 +
...rmationMap.java => HiveTypeInformationMap.java} | 52 +-
.../flink/jdbc/input/MysqlTypeInformationMap.java | 38 +-
...ationMap.java => OracleTypeInformationMap.java} | 49 +-
.../apache/seatunnel/flink/jdbc/sink/JdbcSink.java | 70 +
.../seatunnel/flink/jdbc/source/JdbcSource.java | 161 +-
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../seatunnel/flink/kafka/sink/KafkaSink.java | 3 +
.../flink/kafka/source/KafkaTableStream.java | 2 +-
.../org.apache.seatunnel.flink.BaseFlinkSink | 18 -
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../flink/socket/source/SocketStream.java | 3 +
.../org.apache.seatunnel.flink.BaseFlinkSource | 18 -
.../seatunnel-connectors-spark-dist/pom.xml | 6 +
.../seatunnel-connector-spark-clickhouse/pom.xml | 7 +
.../spark/clickhouse/sink/Clickhouse.scala | 49 +-
.../spark/clickhouse/sink/ClickhouseFile.scala | 37 +-
.../seatunnel/spark/clickhouse/sink/Table.scala | 29 +-
.../sink/filetransfer/RsyncFileTransfer.scala | 65 +-
.../spark/clickhouse/sink/ClickhouseFileTest.scala | 44 +
.../apache/seatunnel/spark/hive/sink/Hive.scala | 4 +-
.../spark/http/source/util/HttpClientUtils.java | 6 +-
.../apache/seatunnel/spark/jdbc/sink/Jdbc.scala | 2 +
.../apache/seatunnel/spark/kafka/sink/Kafka.scala | 8 +-
.../seatunnel/spark/kafka/source/KafkaStream.scala | 20 +-
.../seatunnel/spark/redis/common/Constants.scala | 2 +
.../apache/seatunnel/spark/redis/sink/Redis.scala | 38 +-
.../org/apache/seatunnel/spark/tidb}/Config.scala | 34 +-
.../apache/seatunnel/spark/tidb/sink/Tidb.scala | 15 +-
.../apache/seatunnel/spark/tidb/source/Tidb.scala | 7 +-
.../core/base/command/AbstractCommandArgs.java | 6 +-
.../seatunnel/core/base/config/ConfigParser.java | 45 +
.../core/base/utils/CompressionUtils.java | 9 +-
.../src/test/resources/plugin-mapping.properties | 18 +-
.../src/main/bin/start-seatunnel-sql.sh | 5 +-
.../core/sql/FlinkEnvParameterParser.java} | 30 +-
.../core/sql/classloader/CustomClassLoader.java | 51 +
.../apache/seatunnel/core/sql/job/Executor.java | 164 +-
.../core/sql/FlinkEnvParameterParserTest.java} | 35 +-
.../sql/classloader/CustomClassLoaderTest.java | 24 +-
.../seatunnel/core/sql/job/ExecutorTest.java} | 38 +-
.../seatunnel/core/sql/job/JobInfoTest.java} | 32 +-
seatunnel-core/seatunnel-core-flink/pom.xml | 15 +-
.../src/main/bin/start-seatunnel-flink.sh | 13 +-
.../core/flink/FlinkEnvParameterParser.java | 60 +
.../flink/command/FlinkApiTaskExecuteCommand.java | 49 +-
.../seatunnel/core/flink/config/FlinkRunMode.java | 7 +
.../core/flink/FlinkEnvParameterParserTest.java | 47 +
.../seatunnel/core/flink/FlinkStarterTest.java | 39 +-
.../flink/command/FlinkTaskExecuteCommandTest.java | 64 +
.../core/flink/utils/CommandLineUtilsTest.java | 29 +-
.../src/test/resources/app.conf | 8 +-
.../src/test/resources/sql.conf | 0
seatunnel-core/seatunnel-core-spark/pom.xml | 6 +
.../src/main/bin/start-seatunnel-spark.sh | 10 +-
.../apache/seatunnel/core/spark/SparkStarter.java | 18 +-
.../seatunnel/core}/spark/SparkStarterTest.java | 2 +-
.../starter/config/AbstractExecutionContext.java | 1 +
seatunnel-dist/release-docs/LICENSE | 2 +-
.../{LICENSE-calcite.txt => LICENSE-jmockdata.txt} | 34 +-
seatunnel-dist/src/main/assembly/assembly-bin.xml | 10 +
seatunnel-e2e/pom.xml | 1 +
seatunnel-e2e/seatunnel-flink-e2e/pom.xml | 6 +
.../HttpSourceToConsoleIT.java} | 8 +-
.../httpsource_to_console.conf} | 12 +-
.../pom.xml | 11 +-
.../seatunnel/e2e/flink/sql}/FlinkContainer.java | 56 +-
.../e2e/flink/sql/fake/DatagenToConsoleIT.java} | 12 +-
.../src/test/resources/fake/flink.sql.conf | 7 +-
.../src/test/resources/log4j.properties | 0
seatunnel-e2e/seatunnel-spark-e2e/pom.xml | 5 +
.../{fake => http}/HttpSourceToConsoleIT.java | 2 +-
.../seatunnel-flink-examples/pom.xml | 9 +
.../seatunnel-flink-sql-examples/pom.xml | 4 +
.../src/main/resources/log4j.properties | 0
.../seatunnel-spark-examples/pom.xml | 4 +
.../src/main/resources/log4j.properties | 0
.../seatunnel-transforms-flink/pom.xml | 1 +
.../pom.xml | 5 +-
.../org/apache/seatunnel/flink/transform/UDF.java | 120 +
.../org.apache.seatunnel.flink.BaseFlinkTransform | 2 +-
.../seatunnel-transforms-spark/pom.xml | 1 +
.../pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 2 +-
.../seatunnel/spark/transform/NullRate.scala | 95 +
.../seatunnel/spark/transform/NullRateConfig.scala | 14 +-
seatunnel-ui/.env.development | 18 +
seatunnel-ui/.env.production | 18 +
seatunnel-ui/.eslintignore | 18 +
seatunnel-ui/.eslintrc.js | 71 +
seatunnel-ui/.gitignore | 29 +
seatunnel-ui/.prettierignore | 18 +
.../TableSink.java => seatunnel-ui/.prettierrc.js | 19 +-
seatunnel-ui/README.md | 0
seatunnel-ui/index.html | 30 +
seatunnel-ui/package.json | 50 +
seatunnel-ui/pnpm-lock.yaml | 3062 ++++++++++++++++++++
.../CompositeType.java => seatunnel-ui/src/App.tsx | 17 +-
seatunnel-ui/src/components/chart/index.ts | 68 +
.../Collector.java => seatunnel-ui/src/env.d.ts | 29 +-
.../config/Config.java => seatunnel-ui/src/main.ts | 8 +-
seatunnel-ui/tsconfig.json | 21 +
.../vite.config.ts | 37 +-
tools/dependencies/known-dependencies.txt | 3 +-
188 files changed, 7105 insertions(+), 1282 deletions(-)
create mode 100644 docs/en/connector/flink-sql/ElasticSearch.md
create mode 100644 docs/en/connector/flink-sql/Jdbc.md
create mode 100644 docs/en/connector/flink-sql/Kafka.md
create mode 100644 docs/en/connector/flink-sql/usage.md
create mode 100644 docs/en/transform/nullRate.md
create mode 100644 docs/en/transform/udf.md
create mode 100644 seatunnel-connectors/seatunnel-connectors-flink-sql-dist/pom.xml
copy {seatunnel-connectors-v2/connector-console => seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-6}/pom.xml (67%)
copy {seatunnel-connectors-v2/connector-console => seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-7}/pom.xml (67%)
copy {seatunnel-apis => seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-jdbc}/pom.xml (69%)
copy {seatunnel-connectors-v2/connector-fake => seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-kafka}/pom.xml (82%)
copy seatunnel-connectors/{ => seatunnel-connectors-flink-sql}/pom.xml (69%)
copy seatunnel-connectors/seatunnel-connectors-flink/{seatunnel-connector-flink-console => seatunnel-connector-flink-assert}/pom.xml (96%)
copy {seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/excecutor => seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion}/AssertExecutor.java (69%)
copy {seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel => seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink}/assertion/rule/AssertFieldRule.java (91%)
copy {seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel => seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink}/assertion/rule/AssertRuleParser.java (51%)
create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/sink/AssertSink.java
copy {seatunnel-connectors-v2/connector-assert => seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert}/src/test/java/org/apache/seatunnel/flink/assertion/AssertExecutorTest.java (79%)
copy {seatunnel-connectors-v2/connector-assert => seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert}/src/test/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParserTest.java (90%)
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
create 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/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/Config.java
create 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-fake/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
copy seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-webhook => seatunnel-connectors-flink/seatunnel-connector-flink-http}/pom.xml (66%)
copy seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark => seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink}/http/source/Http.java (54%)
copy seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark => seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink}/http/source/constant/Settings.java (95%)
copy seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark => seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink}/http/source/util/HttpClientResult.java (84%)
copy seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark => seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink}/http/source/util/HttpClientUtils.java (96%)
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
copy seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/{DefaultTypeInformationMap.java => HiveTypeInformationMap.java} (56%)
copy seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/{MysqlTypeInformationMap.java => OracleTypeInformationMap.java} (50%)
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
delete mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
create mode 100644 seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/test/scala/org/apache/seatunnel/spark/clickhouse/sink/ClickhouseFileTest.scala
copy seatunnel-connectors/seatunnel-connectors-spark/{seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg => seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb}/Config.scala (66%)
create mode 100644 seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/ConfigParser.java
copy plugin-mapping.properties => seatunnel-core/seatunnel-core-base/src/test/resources/plugin-mapping.properties (86%)
copy seatunnel-core/{seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/SeatunnelFlink.java => seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParser.java} (58%)
create mode 100644 seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoader.java
copy seatunnel-core/seatunnel-core-flink-sql/src/{main/java/org/apache/seatunnel/core/sql/job/JobInfo.java => test/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParserTest.java} (51%)
copy seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/fake/FakeSourceToConsoleIT.java => seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoaderTest.java (51%)
copy seatunnel-core/seatunnel-core-flink-sql/src/{main/java/org/apache/seatunnel/core/sql/job/JobInfo.java => test/java/org/apache/seatunnel/core/sql/job/ExecutorTest.java} (51%)
copy seatunnel-core/seatunnel-core-flink-sql/src/{main/java/org/apache/seatunnel/core/sql/job/JobInfo.java => test/java/org/apache/seatunnel/core/sql/job/JobInfoTest.java} (53%)
create mode 100644 seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParser.java
create mode 100644 seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParserTest.java
create mode 100644 seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommandTest.java
copy config/flink.streaming.conf.template => seatunnel-core/seatunnel-core-flink/src/test/resources/app.conf (89%)
copy config/flink.sql.conf.template => seatunnel-core/seatunnel-core-flink/src/test/resources/sql.conf (100%)
copy seatunnel-core/{seatunnel-spark-starter/src/test/java/org/apache/seatunnel/core/starter => seatunnel-core-spark/src/test/java/org/apache/seatunnel/core}/spark/SparkStarterTest.java (96%)
copy seatunnel-dist/release-docs/licenses/{LICENSE-calcite.txt => LICENSE-jmockdata.txt} (89%)
copy seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/{fake/FakeSourceToConsoleIT.java => http/HttpSourceToConsoleIT.java} (84%)
copy seatunnel-e2e/seatunnel-flink-e2e/src/test/resources/{fake/fakesource_to_console.conf => http/httpsource_to_console.conf} (88%)
copy seatunnel-e2e/{seatunnel-flink-new-connector-e2e => seatunnel-flink-sql-e2e}/pom.xml (84%)
copy seatunnel-e2e/{seatunnel-flink-new-connector-e2e/src/test/java/org/apache/seatunnel/e2e/flink => seatunnel-flink-sql-e2e/src/test/java/org/apache/seatunnel/e2e/flink/sql}/FlinkContainer.java (68%)
copy seatunnel-e2e/{seatunnel-flink-new-connector-e2e/src/test/java/org/apache/seatunnel/e2e/flink/assertion/FakeSourceToAssertIT.java => seatunnel-flink-sql-e2e/src/test/java/org/apache/seatunnel/e2e/flink/sql/fake/DatagenToConsoleIT.java} (69%)
copy config/flink.sql.conf.template => seatunnel-e2e/seatunnel-flink-sql-e2e/src/test/resources/fake/flink.sql.conf (90%)
copy seatunnel-e2e/{seatunnel-flink-e2e => seatunnel-flink-sql-e2e}/src/test/resources/log4j.properties (100%)
rename seatunnel-e2e/seatunnel-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/{fake => http}/HttpSourceToConsoleIT.java (97%)
copy seatunnel-examples/{seatunnel-flink-examples => seatunnel-flink-sql-examples}/src/main/resources/log4j.properties (100%)
copy seatunnel-examples/{seatunnel-flink-examples => seatunnel-spark-examples}/src/main/resources/log4j.properties (100%)
copy seatunnel-transforms/seatunnel-transforms-flink/{seatunnel-transform-flink-sql => seatunnel-transform-flink-udf}/pom.xml (96%)
create mode 100644 seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java
copy seatunnel-transforms/seatunnel-transforms-flink/{seatunnel-transform-flink-sql => seatunnel-transform-flink-udf}/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform (95%)
copy seatunnel-transforms/seatunnel-transforms-spark/{seatunnel-transform-spark-uuid => seatunnel-transform-spark-null-rate}/pom.xml (96%)
copy seatunnel-transforms/seatunnel-transforms-spark/{seatunnel-transform-spark-json => seatunnel-transform-spark-null-rate}/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform (94%)
create mode 100644 seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/src/main/scala/org/apache/seatunnel/spark/transform/NullRate.scala
copy seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/CommandBuilder.java => seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/src/main/scala/org/apache/seatunnel/spark/transform/NullRateConfig.scala (79%)
create mode 100644 seatunnel-ui/.env.development
create mode 100644 seatunnel-ui/.env.production
create mode 100644 seatunnel-ui/.eslintignore
create mode 100644 seatunnel-ui/.eslintrc.js
create mode 100644 seatunnel-ui/.gitignore
create mode 100644 seatunnel-ui/.prettierignore
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/TableSink.java => seatunnel-ui/.prettierrc.js (73%)
create mode 100644 seatunnel-ui/README.md
create mode 100644 seatunnel-ui/index.html
create mode 100644 seatunnel-ui/package.json
create mode 100644 seatunnel-ui/pnpm-lock.yaml
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/CompositeType.java => seatunnel-ui/src/App.tsx (79%)
create mode 100644 seatunnel-ui/src/components/chart/index.ts
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Collector.java => seatunnel-ui/src/env.d.ts (68%)
copy seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/Config.java => seatunnel-ui/src/main.ts (88%)
create mode 100644 seatunnel-ui/tsconfig.json
copy seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/TransferMethod.scala => seatunnel-ui/vite.config.ts (61%)