2.3.0-beta
版本发布时间: 2022-11-09 11:09:51
apache/seatunnel最新发布版本:2.3.7(2024-08-19 15:40:30)
2.3.0 Beta
[Connector V2]
[New Connector V2 Added]
- [Source] [Kafka] Add Kafka Source Connector (2953)
- [Source] [Pulsar] Add Pulsar Source Connector (1980)
- [Source] [S3File] Add S3 File Source Connector (3119)
- [Source] [JDBC] [Phoenix] Add Phoenix JDBC Source Connector (2499)
- [Source] [JDBC] [SQL Server] Add SQL Server JDBC Source Connector (2646)
- [Source] [JDBC] [Oracle] Add Oracle JDBC Source Connector (2550)
- [Source] [JDBC] [GBase8a] Add GBase8a JDBC Source Connector (3026)
- [Source] [JDBC] [StarRocks] Add StarRocks JDBC Source Connector (3060)
- [Sink] [Kafka] Add Kafka Source Connector (2953)
- [Sink] [S3File] Add S3 File Sink Connector (3119)
[Improve & Bug Fix]
-
[Source] [Fake]
- [Improve] Supports direct definition of data values(row) (2839)
- [Improve] Improve fake source connector: (2944)
- Support user-defined map size
- Support user-defined array size
- Support user-defined string length
- Support user-defined bytes length
- [Improve] Support multiple splits for fake source connector (2974)
- [Improve] Supports setting the number of splits per parallelism and the reading interval between two splits (3098)
-
[Source] [Clickhouse]
- [Improve] Clickhouse Source random use host when config multi-host (3108)
-
[Source] [FtpFile]
-
[Source] [HDFSFile]
-
[Source] [LocalFile]
-
[Source] [OSSFile]
-
[Source] [IoTDB]
- [Improve] Improve IoTDB Source Connector (2917)
- Support extract timestamp、device、measurement from SeaTunnelRow
- Support TINYINT、SMALLINT
- Support flush cache to database before prepareCommit
- [Improve] Improve IoTDB Source Connector (2917)
-
[Source] [JDBC]
-
[Sink] [Assert]
-
[Sink] [Clickhouse]
- [Improve] Clickhouse Support Int128,Int256 Type (3067)
-
[Sink] [Console]
- [Improve] Console sink support print subtask index (3000)
-
[Sink] [Enterprise-WeChat]
- [BugFix] Fix Enterprise-WeChat Sink data serialization (2856)
-
[Sink] [FtpFile]
-
[Sink] [HDFSFile]
-
[Sink] [LocalFile]
-
[Sink] [OSSFile]
-
[Sink] [IoTDB]
-
[Sink] [JDBC]
-
[Sink] [Kudu]
- [Improve] Kudu Sink Connector Support to upsert row (2881)
-
[Sink] [Hive]
- [Improve] Hive Sink supports automatic partition repair (3133)
[Connector V1]
[New Connector V1 Added]
[Improve & Bug Fix]
- [Sink] [Spark-Hbase]
- [BugFix] Handling null values (3099)
[Starter & Core & API]
[Feature & Improve]
- [Improve] [Sink] Support define parallelism for sink connector (2941)
- [Improve] [all] change Log to @slf4j (3001)
- [Improve] [format] [text] Support read & write SeaTunnelRow type (2969)
- [Improve] [api] [flink] extraction unified method (2862)
- [Feature] [deploy] Add Helm charts (2903)
- [Feature] [seatunnel-text-format] (2884)
[Bug Fix]
- [BugFix] Fix assert connector name error in config/plugin_config file (3127)
- [BugFix] [starter] Fix connector-v2 flink & spark dockerfile (3007)
- [BugFix] [core] Fix spark engine parallelism parameter does not working (2965)
- [BugFix] [build] Fix the invalidation of the suppression file of checkstyle in the win10 (2986)
- [BugFix] [format] [json] Fix jackson package conflict with spark (2934)
- [BugFix] [build] Fix the invalidation of the suppression file of checkstyle in the win10 (2986)
- [BugFix] [build] Fix the invalidation of the suppression file of checkstyle in the win10 (2986)
- [BugFix] [seatunnel-translation-base] Fix Source restore state NPE (2878)
[Docs]
- Add coding guide (2995)
[SeaTunnel Engine]
[Feature & Improve]
[Cluster Manager]
- Support Run SeaTunnel Engine in stand-alone.
- Support Run SeaTunnel Engine cluster.
- Do not rely on third-party services(zookeeper etc) to realize the master-worker architecture.
- Autonomous cluster (non centralized).
- Automatic discovery of cluster members.
[Core]
- Support submit Job to SeaTunnel Engine in local mode.
- Support submit Job to SeaTunnel Engine in cluster mode.
- Support Batch Job.
- Support Stream Job.
- Supports batch stream integration, and the batch stream integration feature of all SeaTunnel V2 Connectors can be guaranteed in SeaTunnel Engine.
- Support Distributed Snapshot algorithm Chandy Ramport algorithm and Two-phase Commit. Exactly-Once semantics based on these implementations.
- Support pipeline granularity job scheduling, Ensure that the job can be started under limited resources.
- Support pipeline granularity job restore.
- Sharing threads between tasks to achieve real-time synchronization of a large number of small datasets.