Skip to content

Commit 1d71389

Browse files
authored
[Release][2.3.5][release-note] Add release-note (#6712)
1 parent 790150a commit 1d71389

File tree

1 file changed

+106
-178
lines changed

1 file changed

+106
-178
lines changed

Diff for: release-note.md

+106-178
Original file line numberDiff line numberDiff line change
@@ -1,227 +1,155 @@
1-
# next-release
1+
# 2.3.5 Release Note
22

33
## Bug fix
44

55
### Core
6-
- [Core] [API] Fixed generic class loss for lists (#4421)
7-
- [Core] [API] Fix parse nested row data type key changed upper (#4459)
8-
- [Starter][Flink]Support transform-v2 for flink #3396
9-
- [Flink] Support flink 1.14.x #3963
10-
- [Core][Translation][Spark] Fix SeaTunnelRowConvertor fail to convert when schema contains row type (#5170)
6+
7+
- [fix] fix get seatunnel row size npe issue (#6681)
8+
- [Hotfix] Fix DEFAULT TABLE problem (#6352)
9+
- [Chore] Fix `file` spell errors (#6606)
10+
- [BugFix][Spark-translation] map type cast error (#6552)
11+
- [Hotfix] Fix spark example (#6486)
12+
- [Hotfix] Fix compile error (#6463)
1113

1214
### Transformer
13-
- [Spark] Support transform-v2 for spark (#3409)
14-
- [ALL]Add FieldMapper Transform #3781
15-
- [All]Add JsonPath Transform #5633
15+
16+
- [Fix][SQLTransform] fix the scale loss for the sql transform (#6553)
17+
- [Bug] Fix minus constant error in SQLTransform (#6533)
18+
1619
### Connectors
17-
- [Elasticsearch] Support https protocol & compatible with opensearch
18-
- [Hbase] Add hbase sink connector #4049
19-
- [Clickhouse] Fix clickhouse old version compatibility #5326
20-
- [Easysearch] Support INFINI Easysearch #5933
20+
21+
- [Fix][Kafka-Sink] fix kafka sink factory option rule (#6657)
22+
- [Hotfix] fix http source can not read yyyy-MM-dd HH:mm:ss format bug & Improve DateTime Utils (#6601)
23+
- [Bug] Fix OrcWriteStrategy/ParquetWriteStrategy doesn't login with kerberos (#6472)
24+
- [Fix][Doc] Fix FTP sink config key `username` to `user` (#6627)
25+
- [E2E] Fix AmazondynamodbIT unstable (#6640)
26+
- [Fix][Connector-V2] Fix add hive partition error when partition already existed (#6577)
27+
- [Fix][Connector-V2] Fixed doris/starrocks create table sql parse error (#6580)
28+
- [Fix][Connector-V2] Fix doris sink can not be closed when stream load not read any data (#6570)
29+
- [Fix][Connector-V2] Fix connector support SPI but without no args constructor (#6551)
30+
- [Fix][Connector-V2] Fix doris source select fields loss primary key information (#6339)
31+
- [Fix][FakeSource] fix random from template not include the latest value issue (#6438)
32+
- [Fix][Connector-V2] Fix mongodb cdc start up mode option values not right (#6338)
33+
- [BugFix][Connector-file-sftp] Fix SFTPInputStream.close does not correctly trigger the closing of the file stream (#6323) (#6329)
34+
- [Fix] Fix doris stream load failed not reported error (#6315)
35+
- [fix][connector-rocketmq]Fix a NPE problem when checkpoint.interval is set too small(#6624)
36+
- [Bugfix][TDengine] Fix the issue of losing the driver due to multiple calls to the submit job REST API #6581 (#6596)
37+
- [Fix][StarRocks] Fix NPE when upstream catalogtable table path only have table name part (#6540)
38+
2139
### Formats
22-
- [Canal]Support read canal format message #3950
23-
- [Debezium]Support debezium canal format message #3981
2440

25-
### Connector-V2
41+
- [Bug] [formats] Fix fail to parse line when content contains the file delimiter (#6589)
2642

27-
- [Json-format] [Canal-Json] Fix json deserialize NPE (#4195)
28-
- [Connector-V2] [Jdbc] Field aliases are not supported in the query of jdbc source. (#4210)
29-
- [Connector-V2] [Jdbc] Fix connection failure caused by connection timeout. (#4322)
30-
- [Connector-V2] [Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)
31-
- [Connector-V2] [JDBC] Fix TiDBCatalog without open (#4718)
32-
- [Connector-V2] [Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)
33-
- [Connector-V2] [Pulsar] Fix the bug that can't consume messages all the time. (#4125)
34-
- [Connector-V2] [Eleasticsearch] Document description error (#4390)
35-
- [Connector-V2] [Eleasticsearch] Source deserializer error and inappropriate (#4233)
36-
- [Connector-V2] [Kafka] Fix KafkaProducer resources have never been released. (#4302)
37-
- [Connector-V2] [Kafka] Fix the permission problem caused by client.id. (#4246)
38-
- [Connector-V2] [Kafka] Fix KafkaConsumerThread exit caused by commit offset error. (#4379)
39-
- [Connector-V2] [Mongodb] Mongodb support cdc sink. (#4833)
40-
- [Connector-V2] [kafka] Fix the problem that the partition information can not be obtained when kafka is restored (#4764)
41-
- [Connector-V2] [SFTP] Fix incorrect exception handling logic (#4720)
42-
- [Connector-V2] [File] Fix read temp file (#4876)
43-
- [Connector-V2] [CDC Base] Solving the ConcurrentModificationException caused by snapshotState being modified concurrently. (#4877)
44-
- [Connector-V2] [Doris] update last checkpoint id when doing snapshot (#4881)
45-
- [Connector-v2] [kafka] Fix the short interval of pull data settings and revise the format (#4875)
46-
- [Connector-v2] [RabbitMQ] Fix reduplicate ack msg bug and code style (#4842)
47-
- [Connector-V2] [Jdbc] Fix the error of extracting primary key column in sink (#4815)
48-
- [Connector-V2] [Jdbc] Fix reconnect throw close statement exception (#4801)
49-
- [Connector-V2] [Jdbc] Fix sqlserver system table case sensitivity (#4806)
50-
- [Connector-v2] [File] Fix configuration file format and error comments (#4762)
51-
- [Connector-v2] [Jdbc] Fix oracle sql table identifier (#4754)
52-
- [Connector-v2] [Clickhouse] fix get clickhouse local table name with closing bracket from distributed table engineFull (#4710)
53-
- [Connector-v2] [CDC] Fix jdbc connection leak for mysql (#5037)
54-
- [Connector-v2] [File] Fix WriteStrategy parallel writing thread unsafe issue #5546
55-
- [Connector-v2] [File] Inject FileSystem to OrcWriteStrategy
56-
- [Connector-v2] [File] Support assign encoding for file source/sink (#5973)
5743

5844
### Zeta(ST-Engine)
5945

60-
- [Zeta] Fix LogicalDagGeneratorTest testcase (#4401)
61-
- [Zeta] Fix MultipleTableJobConfigParser parse only one transform (#4412)
62-
- [Zeta] Fix missing common plugin jars (#4448)
63-
- [Zeta] Fix handleCheckpointError be called while checkpoint already complete (#4442)
64-
- [Zeta] Fix job error message is not right bug (#4463)
65-
- [Zeta] Fix finding TaskGroup deployment node bug (#4449)
66-
- [Zeta] Fix the bug of conf (#4488)
67-
- [Zeta] Fix Connector load logic from zeta (#4510)
68-
- [Zeta] Fix conflict dependency of hadoop-hdfs (#4509)
69-
- [Zeta] Fix TaskExecutionService synchronized lock will not release (#4886)
70-
- [Zeta] Fix TaskExecutionService will return not active ExecutionContext (#4869)
71-
- [Zeta] Fix deploy operation timeout but task already finished bug (#4867)
72-
- [Zeta] Fix restoreComplete Future can't be completed when cancel task (#4863)
73-
- [Zeta] Fix IMap operation timeout bug (#4859)
74-
- [Zeta] fix pipeline state not right bug (#4823)
75-
- [Zeta] Fix the incorrect setting of transform parallelism (#4814)
76-
- [Zeta] Fix master active bug (#4855)
77-
- [Zeta] Fix completePendingCheckpoint concurrent action (#4854)
78-
- [Zeta] Fix engine runtime error (#4850)
79-
- [Zeta] Fix TaskGroupContext always hold classloader so classloader can't recycle (#4849)
80-
- [Zeta] Fix task `notifyTaskStatusToMaster` failed when job not running or failed before run (#4847)
81-
- [Zeta] Fix cpu load problem (#4828)
82-
- [zeta] Fix the deadlock issue with JDBC driver loading (#4878)
83-
- [zeta] dynamically replace the value of the variable at runtime (#4950)
84-
- [Zeta] Add from_unixtime function (#5462)
85-
- [zeta] Fix CDC task restore throw NPE (#5507)
46+
- [Hotfix] fix http source can not read yyyy-MM-dd HH:mm:ss format bug & Improve DateTime Utils (#6601)
47+
- [Fix][Zeta] Fix the thread stuck problem caused by savepoint checking mechanism (#6568)
48+
- [Fix][Zeta] improve the local mode hazelcast connection (#6521)
49+
- [Fix][Zeta] Fix thread classloader be set to null when use cache mode (#6509)
50+
- [Bug] [zeta] Fix null pointer exception when submitting jobs (#6492)
51+
- [bugfix] [Zeta] Fix the problem of class loader not releasing when using REST API to submit jobs
52+
- [BUG][Zeta]job name Display error #6470
53+
- [Hotfix][Zeta] Fix job deadlock when schema change (#6389)
8654

8755
### E2E
8856

89-
- [E2E] [Kafka] Fix kafka e2e testcase (#4520)
90-
- [Container Version] Fix risk of unreproducible test cases #4591
91-
- [E2e] [Mysql-cdc] Removing the excess MySqlIncrementalSourceIT e2e reduces the CI time (#4738)
92-
- [E2E] [Common] Update test container version of seatunnel engine (#5323)
93-
- [E2E] [Jdbc] Fix not remove docker image after test finish on jdbc suite (#5586)
57+
- [E2E] Enable StarRocksCDCSinkIT (#6626)
58+
9459

9560
## Improve
9661

97-
- [Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)
62+
- [Doc][Improve] Add Support Chinese for seatunnel-engine (#6656)
63+
- [Doc][Improve]Add Support Chinese for start-v2/locally/quick-start-flink.md and start-v2/locally/quick-start-spark.md (#6412)
64+
- [Improve] add icon for idea (#6394)
65+
- [Improve] Add deprecated annotation for `ReadonlyConfig::toConfig` (#6353)
66+
9867

9968
### Core
10069

101-
- [Core] [Spark] Push transform operation from Spark Driver to Executors (#4503)
102-
- [Core] [Starter] Optimize code structure & remove redundant code (#4525)
103-
- [Core] [Translation] [Flink] Optimize code structure & remove redundant code (#4527)
104-
- [Core] [Starter] Add check of sink and source config to avoid null pointer exception. (#4734)
105-
- [Core] [Flink] Remove useless stage type related codes. (#5650)
70+
- [Improve][RestAPI] always return jobId when call getJobInfoById API (#6422)
71+
- [Improve][RestAPI] return finished job info when job is finished (#6576)
72+
- [Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)
73+
- [Improve] Add SaveMode log of process detail (#6375)
74+
- [Improve][API] Unify type system api(data & type) (#5872)
10675

10776
### Formats
10877

109-
- [Json] Remove assert key word. (#5919)
110-
- [Formats] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5948)
111-
- [Formats] Refactor exception catch for `ignoreParseErrors`. (#6065)
78+
- [Improve] Improve read with parquet type convert error (#6683)
11279

11380
### Connector-V2
11481

115-
- [Connector-V2] [CDC] Improve startup.mode/stop.mode options (#4360)
116-
- [Connector-V2] [CDC] Optimize jdbc fetch-size options (#4352)
117-
- [Connector-V2] [CDC] Fix chunk start/end parameter type error (#4777)
118-
- [Connector-V2] [SQLServer] Fix sqlserver catalog (#4441)
119-
- [Connector-V2] [StarRocks] Improve StarRocks Serialize Error Message (#4458)
120-
- [Connector-V2] [Jdbc] add the log for sql and update some style (#4475)
121-
- [Connector-V2] [Jdbc] Fix the table name is not automatically obtained when multiple tables (#4514)
122-
- [Connector-V2] [S3 & Kafka] Delete unavailable S3 & Kafka Catalogs (#4477)
123-
- [Connector-V2] [Pulsar] Support Canal Format
124-
- [Connector-V2] [CDC base] Implement Sample-based Sharding Strategy with Configurable Sampling Rate (#4856)
125-
- [Connector-V2] [SelectDB] Add a jobId to the selectDB label to distinguish between tasks (#4864)
126-
- [Connector-V2] [Doris] Add a jobId to the doris label to distinguish between tasks (#4839) (#4853)
127-
- [Connector-v2] [Mongodb]Refactor mongodb connector (#4620)
128-
- [Connector-v2] [Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)
129-
- [Connector-v2] [Neo4j] Supports neo4j sink batch write mode (#4835)
130-
- [Transform-V2] Optimize SQL Transform package and Fix Spark type conversion bug of transform (#4490)
131-
- [Connector-V2] [Common] Remove assert key word (#5915)
132-
- [Connector-V2] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5978)
82+
- [Improve][Connector-V2]Support multi-table sink feature for redis (#6314)
83+
- [Improve][Connector-V2] oracle cdc e2e optimization (#6232)
84+
- [Improve][Connector-V2]Support multi-table sink feature for httpsink (#6316)
85+
- [Improve][Connector-V2] Support INFINI Easysearch (#5933)
86+
- [Improve][Connector-V2] Support hadoop ha and kerberos for paimon sink (#6585)
87+
- [Improve][CDC-Connector]Fix CDC option rule. (#6454)
88+
- [Improve][CDC] Optimize memory allocation for snapshot split reading (#6281)
89+
- [Improve][Connector-V2] Support TableSourceFactory on StarRocks (#6498)
90+
- [Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)
91+
- [Improve] StarRocksSourceReader use the existing client (#6480)
92+
- [Improve][JDBC] Optimized code style for getting jdbc field types (#6583)
93+
- [Improve][Connector-V2] Add ElasticSearch type converter (#6546)
94+
- [Improve][Connector-V2] Support read orc with schema config to cast type (#6531)
95+
- [Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)
96+
- [Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)
97+
- [Improve][CDC] Optimize split state memory allocation in increment phase (#6554)
98+
- [Improve][CDC] Improve read performance when record not contains schema field (#6571)
99+
- [Improve][Jdbc] Add quote identifier for sql (#6669)
100+
- [Improve] Add disable 2pc in SelectDB cloud sink (#6266)
101+
- [Doc][Improve] Add Support Kerberos Auth For Kafka Connector #6653
133102

134103
### CI
135104

136105
- [CI] Fix error repository name in ci config files (#4795)
137-
- [CI][E2E][Zeta] Increase Zeta checkpoint timeout to avoid connector-file-sftp-e2e failed frequently (#5339)
138106

139107
### Zeta(ST-Engine)
140108

141-
- [Zeta] Support run the server through daemon mode (#4161)
142-
- [Zeta] Change ClassLoader To Improve the SDK compatibility of the client (#4447)
143-
- [Zeta] Client Support Async Submit Job (#4456)
144-
- [Zeta] Add more detailed log output. (#4446)
145-
- [Zeta] Improve seatunnel-cluster.sh (#4435)
146-
- [Zeta] Reduce CPU Cost When Task Not Ready (#4479)
147-
- [Zeta] Add parser log (#4485)
148-
- [Zeta] Remove redundant code (#4489)
149-
- [Zeta] Remove redundancy code in validateSQL (#4506)
150-
- [Zeta] Improve JobMetrics fetch performance (#4467)
151-
- [Zeta] Reduce the operation count of imap_running_job_metrics (#4861)
152-
- [Zeta] Speed up listAllJob function (#4852)
153-
- [Zeta] async execute checkpoint trigger and other block method (#4846)
154-
- [Zeta] Reduce the number of IMAPs used by checkpointIdCounter (#4832)
155-
- [Zeta] Cancel pipeline add retry to avoid cancel failed. (#4792)
156-
- [Zeta] Improve Zeta operation max count and ignore NPE (#4787)
157-
- [Zeta] Remove serialize(deserialize) cost when use shuffle action (#4722)
158-
- [zeta] Checkpoint exception status messages exclude state data (#5547)
159-
- [Zeta] Remove assert key words (#5947)
109+
- [Improve][Zeta] Add classloader cache mode to fix metaspace leak (#6355)
110+
- [Improve][Test] Fix test unstable on `ResourceManger` and `EventReport` module (#6620)
111+
- [Improve][Test] Run all test when code merged into dev branch (#6609)
112+
- [Improve][Test] Make classloader cache testing more stable (#6597)
113+
- [Improve][Zeta][storage] update hdfs configuration, support more parameters (#6547)
114+
- [Improve][Zeta]Optimize the logic of RestHttpGetCommandProcessor#getSeaTunnelServer() (#6666)
115+
116+
117+
### Transformer
118+
119+
- [Improve][Transform] Sql transform support inner strucy query (#6484)
120+
- [Improve][Transform] Remove Fallback during parsing Transform process (#6644)
121+
- [Improve][Transform] Remove can't find field exception (#6691)
122+
160123

161124
## Feature
162125

163126
### Core
164127

165-
- [Core] [API] Support convert strings as List<T> option (#4362)
166-
- [Core] [API] Add copy method to Catalog codes (#4414)
167-
- [Core] [API] Add options check before create source and sink and transform in FactoryUtil (#4424)
168-
- [Core] [Shade] Add guava shade module (#4358)
169-
- [Core] [Spark] Support SeaTunnel Time Type (#5188)
170-
- [Core] [Flink] Support Decimal Type with configurable precision and scale (#5419)
171-
- [Core] [API] Support hocon style declare row type in generic type (#6187)
128+
- [Feature][Tool] Add connector check script for issue 6199 (#6635)
129+
- [Feature][Core] Support listening for message delayed events in cdc source (#6634)
130+
- [Feature][Core] Support event listener for job (#6419)
172131

173132
### Connector-V2
174133

175-
- [Connector-V2] [CDC] [SQLServer] Support multi-table read (#4377)
176-
- [Connector-V2] [Kafka] Kafka source supports data deserialization failure skipping (#4364)
177-
- [Connector-V2] [Jdbc] [TiDB] Add TiDB catalog (#4438)
178-
- [Connector-V2] [File] Add file excel sink and source (#4164)
179-
- [Connector-v2] [Snowflake] Add Snowflake Source&Sink connector (#4470)
180-
- [Connector-V2] [Pular] support read format for pulsar (#4111)
181-
- [Connector-V2] [Paimon] Introduce paimon connector (#4178)
182-
- [Connector V2] [Cassandra] Expose configurable options in Cassandra (#3681)
183-
- [Connector V2] [Jdbc] Supports GEOMETRY data type for PostgreSQL (#4673)
184-
- [Connector V2] [Jdbc] Supports Kingbase database (#4803)
185-
- [Transform-V2] Add UDF SPI and an example implement for SQL Transform plugin (#4392)
186-
- [Transform-V2] Support copy field list (#4404)
187-
- [Transform-V2] Add support CatalogTable for FieldMapperTransform (#4423)
188-
- [Transform-V2] Add CatalogTable support for ReplaceTransform (#4411)
189-
- [Transform-V2] Add Catalog support for FilterRowKindTransform (#4420)
190-
- [Transform-V2] Add support CatalogTable for FilterFieldTransform (#4422)
191-
- [Transform-V2] Add catalog support for SQL Transform plugin (#4819)
192-
- [Connector-V2] [Assert] Support check the precision and scale of Decimal type (#6110)
193-
- [Connector-V2] [Assert] Support field type assert and field value equality assert for full data types (#6275)
194-
- [Connector-V2] [Iceberg] Support iceberg sink #6198
134+
- [Feature][connector-v2] add xugudb connector (#6561)
135+
- [Feature][Connector-V2] Support multi-table sink feature for paimon #5652 (#6449)
136+
- [Feature][Connectors-V2][File]support assign encoding for file source/sink (#6489)
137+
- [Feature][Connector]update pgsql-cdc publication for add table (#6309)
138+
- [Feature][Paimon] Support specify paimon table write properties, partition keys and primary keys (#6535)
139+
- [Feature][Feature] Support nanosecond in Doris DateTimeV2 type (#6358)
140+
- [Feature][Feature] Support nanosecond in SelectDB DateTimeV2 type (#6332)
141+
- [Feature][Feature] Supports iceberg sink #6198 (#6265)
195142

196143
### Zeta(ST-Engine)
197144

198-
- [Zeta] Support for mixing Factory and Plugin SPI (#4359)
199-
- [Zeta] Add get running job info by jobId rest api (#4140)
200-
- [Zeta] Add REST API To Get System Monitoring Information (#4315)
201-
- [Transform V2 & Zeta] Make SplitTransform Support CatalogTable And CatalogTable Evolution (#4396)
202-
- [Zeta] Move driver into lib directory and change operation count (#4845)
203-
- [Zeta] Add Metaspace size default value to config file (#4848)
204-
- [Zeta] Reduce the frequency of fetching data from imap (#4851)
205-
- [Zeta] Add OSS support for Imap storage to cluster-mode type (#4683)
206-
- [Zeta] Improve local mode startup request ports (#4660)
145+
- [Zeta] Support config job retry times in job config (#6690)
146+
207147

208148
## Docs
209149

210-
- [Docs] Optimizes part of the Doris and SelectDB connector documentation (#4365)
211-
- [Docs] Fix docs code style (#4368)
212-
- [Docs] Update jdbc doc and kafka doc (#4380)
213-
- [Docs] Fix max_retries default value is 0. (#4383)
214-
- [Docs] Fix markdown syntax (#4426)
215-
- [Docs] Fix Kafka Doc Error Config Key "kafka." (#4427)
216-
- [Docs] Add Transform to Quick Start v2 (#4436)
217-
- [Docs] Fix Dockerfile and seatunnel-flink.yaml in Set Up with Kubernetes (#4788)
218-
- [Docs] Fix Mysql sink format doc (#4800)
219-
- [Docs] Add the generate sink sql parameter for the jdbc sink document (#4797)
220-
- [Docs] Add the generate sink sql parameter And example (#4769)
221-
- [Docs] Redshift add defaultRowFetchSize (#4616)
222-
- [Docs] Refactor connector-v2 docs using unified format Mysql (#4590)
223-
- [Docs] Add Value types in Java to Schema features (#5087)
224-
- [Docs] Replace username by user in the options of FtpFile (#5421)
225-
- [Docs] Add how to configure logging related parameters of SeaTunnel-E2E Test (#5589)
226-
- [Docs] Remove redundant double quotation mark from an example code (#5845)
227-
- [Docs] Add Hive JDBC reference value (#5882)
150+
- [Docs] fix kafka format typo (#6633)
151+
- [Fix][Doc] Fixed links in some documents (#6673)
152+
- [Fix][Doc] Fix some spell errors (#6628)
153+
- [Fix][Doc] Fixed typography error in starrocks sink document (#6579)
154+
- [Hotfix][Doc][Chinese] Fix invalid link about configure logging related parameters (#6442)
155+
- [Fix][Doc]Seatunnel Engine/checkpoint-storage.md doc error(#6369)

0 commit comments

Comments
 (0)