|
1 | | -# next-release |
| 1 | +# 2.3.7 Release Note |
2 | 2 |
|
3 | 3 | ## Bug fix |
4 | 4 |
|
5 | | -### 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) |
11 | | - |
12 | | -### Transformer |
13 | | -- [Spark] Support transform-v2 for spark (#3409) |
14 | | -- [ALL]Add FieldMapper Transform #3781 |
15 | | -- [All]Add JsonPath Transform #5633 |
16 | | -### 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 |
21 | | -- [Web3j] add Web3j source connector #6598 |
22 | | -### Formats |
23 | | -- [Canal]Support read canal format message #3950 |
24 | | -- [Debezium]Support debezium canal format message #3981 |
25 | | - |
26 | 5 | ### Connector-V2 |
27 | 6 |
|
28 | | -- [Json-format] [Canal-Json] Fix json deserialize NPE (#4195) |
29 | | -- [Connector-V2] [Jdbc] Field aliases are not supported in the query of jdbc source. (#4210) |
30 | | -- [Connector-V2] [Jdbc] Fix connection failure caused by connection timeout. (#4322) |
31 | | -- [Connector-V2] [Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471) |
32 | | -- [Connector-V2] [JDBC] Fix TiDBCatalog without open (#4718) |
33 | | -- [Connector-V2] [Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866) |
34 | | -- [Connector-V2] [Pulsar] Fix the bug that can't consume messages all the time. (#4125) |
35 | | -- [Connector-V2] [Eleasticsearch] Document description error (#4390) |
36 | | -- [Connector-V2] [Eleasticsearch] Source deserializer error and inappropriate (#4233) |
37 | | -- [Connector-V2] [Kafka] Fix KafkaProducer resources have never been released. (#4302) |
38 | | -- [Connector-V2] [Kafka] Fix the permission problem caused by client.id. (#4246) |
39 | | -- [Connector-V2] [Kafka] Fix KafkaConsumerThread exit caused by commit offset error. (#4379) |
40 | | -- [Connector-V2] [Mongodb] Mongodb support cdc sink. (#4833) |
41 | | -- [Connector-V2] [kafka] Fix the problem that the partition information can not be obtained when kafka is restored (#4764) |
42 | | -- [Connector-V2] [SFTP] Fix incorrect exception handling logic (#4720) |
43 | | -- [Connector-V2] [File] Fix read temp file (#4876) |
44 | | -- [Connector-V2] [CDC Base] Solving the ConcurrentModificationException caused by snapshotState being modified concurrently. (#4877) |
45 | | -- [Connector-V2] [Doris] update last checkpoint id when doing snapshot (#4881) |
46 | | -- [Connector-v2] [kafka] Fix the short interval of pull data settings and revise the format (#4875) |
47 | | -- [Connector-v2] [RabbitMQ] Fix reduplicate ack msg bug and code style (#4842) |
48 | | -- [Connector-V2] [Jdbc] Fix the error of extracting primary key column in sink (#4815) |
49 | | -- [Connector-V2] [Jdbc] Fix reconnect throw close statement exception (#4801) |
50 | | -- [Connector-V2] [Jdbc] Fix sqlserver system table case sensitivity (#4806) |
51 | | -- [Connector-v2] [File] Fix configuration file format and error comments (#4762) |
52 | | -- [Connector-v2] [Jdbc] Fix oracle sql table identifier (#4754) |
53 | | -- [Connector-v2] [Clickhouse] fix get clickhouse local table name with closing bracket from distributed table engineFull (#4710) |
54 | | -- [Connector-v2] [CDC] Fix jdbc connection leak for mysql (#5037) |
55 | | -- [Connector-v2] [File] Fix WriteStrategy parallel writing thread unsafe issue #5546 |
56 | | -- [Connector-v2] [File] Inject FileSystem to OrcWriteStrategy |
57 | | -- [Connector-v2] [File] Support assign encoding for file source/sink (#5973) |
58 | | -- [Connector-v2] [Mongodb] Support to convert to double from numeric type that mongodb saved it as numeric internally (#6997) |
59 | | -- [Connector-v2] [Redis] Using scan replace keys operation command,support batchWrite in single mode(#7030,#7085) |
60 | | -- [Connector-V2] [Clickhouse] Add a new optional configuration `clickhouse.config` to the source connector of ClickHouse (#7143) |
| 7 | +- [Hotfix][MySQL-CDC] Fix ArrayIndexOutOfBoundsException in mysql binlog read (#7381) (#40c5f313e) |
| 8 | +- [Fix][Doris] Fix doris primary key order and fields order are inconsistent (#7377) (#464da8fb9) |
| 9 | +- [Bugfix][Doris] Fix Json serialization, null value causes data error problem (#7b19df585) |
| 10 | +- [Hotfix][Jdbc] Fix jdbc compile error (#7359) (#2769ed502) |
| 11 | +- [Fix][OceanBase] Remove OceanBase catalog's dependency on mysql driver (#7311) (#3130ae089) |
| 12 | +- [Fix][Tdengine] Fix sql exception and concurrentmodifyexception when connect to taos and read data (#a18fca800) |
| 13 | +- [Hotfix][Kafka] Fix kafka consumer log next startup offset (#7312) (#891652399) |
| 14 | +- [Fix][Doris] Fix the abnormality of deleting data in CDC scenario. (#7315) (#bb2c91240) |
| 15 | +- [hotfix][Hbase]fix and optimize hbase source problem (#7148) (#34a6b8e9f) |
| 16 | +- [Fix][Iceberg] Unable to create a source for identifier 'Iceberg'. #7182 (#7279) (#489749170) |
61 | 17 |
|
62 | 18 | ### Zeta(ST-Engine) |
63 | 19 |
|
64 | | -- [Zeta] Fix LogicalDagGeneratorTest testcase (#4401) |
65 | | -- [Zeta] Fix MultipleTableJobConfigParser parse only one transform (#4412) |
66 | | -- [Zeta] Fix missing common plugin jars (#4448) |
67 | | -- [Zeta] Fix handleCheckpointError be called while checkpoint already complete (#4442) |
68 | | -- [Zeta] Fix job error message is not right bug (#4463) |
69 | | -- [Zeta] Fix finding TaskGroup deployment node bug (#4449) |
70 | | -- [Zeta] Fix the bug of conf (#4488) |
71 | | -- [Zeta] Fix Connector load logic from zeta (#4510) |
72 | | -- [Zeta] Fix conflict dependency of hadoop-hdfs (#4509) |
73 | | -- [Zeta] Fix TaskExecutionService synchronized lock will not release (#4886) |
74 | | -- [Zeta] Fix TaskExecutionService will return not active ExecutionContext (#4869) |
75 | | -- [Zeta] Fix deploy operation timeout but task already finished bug (#4867) |
76 | | -- [Zeta] Fix restoreComplete Future can't be completed when cancel task (#4863) |
77 | | -- [Zeta] Fix IMap operation timeout bug (#4859) |
78 | | -- [Zeta] fix pipeline state not right bug (#4823) |
79 | | -- [Zeta] Fix the incorrect setting of transform parallelism (#4814) |
80 | | -- [Zeta] Fix master active bug (#4855) |
81 | | -- [Zeta] Fix completePendingCheckpoint concurrent action (#4854) |
82 | | -- [Zeta] Fix engine runtime error (#4850) |
83 | | -- [Zeta] Fix TaskGroupContext always hold classloader so classloader can't recycle (#4849) |
84 | | -- [Zeta] Fix task `notifyTaskStatusToMaster` failed when job not running or failed before run (#4847) |
85 | | -- [Zeta] Fix cpu load problem (#4828) |
86 | | -- [zeta] Fix the deadlock issue with JDBC driver loading (#4878) |
87 | | -- [zeta] dynamically replace the value of the variable at runtime (#4950) |
88 | | -- [Zeta] Add from_unixtime function (#5462) |
89 | | -- [zeta] Fix CDC task restore throw NPE (#5507) |
| 20 | +- [Fix][Zeta] Fix task can not end cause by lock metrics failed (#7357) (#6a7df83b3) |
| 21 | +- [Hotfix][Zeta] Fix task cannot be stopped when system is busy (#7292) (#73632bad2) |
| 22 | +- [Hotfix][Zeta] Fix task cannot be stopped when system is busy (#7280) (#3ccc6a8bd) |
90 | 23 |
|
91 | 24 | ### E2E |
92 | 25 |
|
93 | | -- [E2E] [Kafka] Fix kafka e2e testcase (#4520) |
94 | | -- [Container Version] Fix risk of unreproducible test cases #4591 |
95 | | -- [E2e] [Mysql-cdc] Removing the excess MySqlIncrementalSourceIT e2e reduces the CI time (#4738) |
96 | | -- [E2E] [Common] Update test container version of seatunnel engine (#5323) |
97 | | -- [E2E] [Jdbc] Fix not remove docker image after test finish on jdbc suite (#5586) |
| 26 | +- [Fix][Http] Fix http e2e case (#7356) (#9d161d24e) |
98 | 27 |
|
99 | 28 | ## Improve |
100 | 29 |
|
101 | | -- [Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634) |
102 | | - |
103 | 30 | ### Core |
104 | 31 |
|
105 | | -- [Core] [Spark] Push transform operation from Spark Driver to Executors (#4503) |
106 | | -- [Core] [Starter] Optimize code structure & remove redundant code (#4525) |
107 | | -- [Core] [Translation] [Flink] Optimize code structure & remove redundant code (#4527) |
108 | | -- [Core] [Starter] Add check of sink and source config to avoid null pointer exception. (#4734) |
109 | | -- [Core] [Flink] Remove useless stage type related codes. (#5650) |
| 32 | +- [Improve][Flink] optimize method name (#7372) (#7e7738430) |
| 33 | +- [Improve][API] Check catalog table fields name legal before send to downstream (#7358) (#fa34ac98b) |
| 34 | +- [Improve][Flink] refactor flink proxy source/sink (#7355) (#068c5e3e3) |
| 35 | +- [Improve][API] Make sure the table name in TablePath not be null (#7252) (#764d8b0bc) |
| 36 | +- [Improve][Core] Improve base on plugin name of lookup strategy (#7278) (#21c4f5245) |
110 | 37 |
|
111 | | -### Formats |
| 38 | +### Connector-V2 |
112 | 39 |
|
113 | | -- [Json] Remove assert key word. (#5919) |
114 | | -- [Formats] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5948) |
115 | | -- [Formats] Refactor exception catch for `ignoreParseErrors`. (#6065) |
| 40 | +- [Improve][multi-table] Add multi-table sink option check (#7360) (#2489f6446) |
| 41 | +- [Improve][Console] Update ConsoleSinkFactory.java (#7350) (#921662722) |
| 42 | +- [Improve][Jdbc] Skip all index when auto create table to improve performance of write (#7288) (#dc3c23981) |
| 43 | +- [Improve][Doris] Improve doris error msg (#7343) (#16950a67c) |
| 44 | +- [Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333) (#16eeb1c12) |
| 45 | +- [Improve][Jdbc] Merge user config primary key when create table (#7313) (#819c68565) |
| 46 | +- [Improve][Jdbc] Optimize the way of databases and tables are checked for existence (#7261) (#f012b2a6f) |
116 | 47 |
|
117 | | -### Connector-V2 |
| 48 | +### Transforms-V2 |
118 | 49 |
|
119 | | -- [Connector-V2] [CDC] Improve startup.mode/stop.mode options (#4360) |
120 | | -- [Connector-V2] [CDC] Optimize jdbc fetch-size options (#4352) |
121 | | -- [Connector-V2] [CDC] Fix chunk start/end parameter type error (#4777) |
122 | | -- [Connector-V2] [SQLServer] Fix sqlserver catalog (#4441) |
123 | | -- [Connector-V2] [StarRocks] Improve StarRocks Serialize Error Message (#4458) |
124 | | -- [Connector-V2] [Jdbc] add the log for sql and update some style (#4475) |
125 | | -- [Connector-V2] [Jdbc] Fix the table name is not automatically obtained when multiple tables (#4514) |
126 | | -- [Connector-V2] [S3 & Kafka] Delete unavailable S3 & Kafka Catalogs (#4477) |
127 | | -- [Connector-V2] [Pulsar] Support Canal Format |
128 | | -- [Connector-V2] [CDC base] Implement Sample-based Sharding Strategy with Configurable Sampling Rate (#4856) |
129 | | -- [Connector-V2] [SelectDB] Add a jobId to the selectDB label to distinguish between tasks (#4864) |
130 | | -- [Connector-V2] [Doris] Add a jobId to the doris label to distinguish between tasks (#4839) (#4853) |
131 | | -- [Connector-v2] [Mongodb]Refactor mongodb connector (#4620) |
132 | | -- [Connector-v2] [Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755) |
133 | | -- [Connector-v2] [Neo4j] Supports neo4j sink batch write mode (#4835) |
134 | | -- [Transform-V2] Optimize SQL Transform package and Fix Spark type conversion bug of transform (#4490) |
135 | | -- [Connector-V2] [Common] Remove assert key word (#5915) |
136 | | -- [Connector-V2] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5978) |
137 | | - |
138 | | -### CI |
139 | | - |
140 | | -- [CI] Fix error repository name in ci config files (#4795) |
141 | | -- [CI][E2E][Zeta] Increase Zeta checkpoint timeout to avoid connector-file-sftp-e2e failed frequently (#5339) |
| 50 | +- [Improve][DynamicCompile] Improve DynamicCompile transform (#7319) (#064fcad36) |
| 51 | +- [Improve][SQL] Remove escape identifier from output fields (#7297) (#82f5d8c71) |
| 52 | +- [Improve][DynamicCompile] Improve DynamicCompile transform (#7264) (#9df557cb1) |
142 | 53 |
|
143 | | -### Zeta(ST-Engine) |
| 54 | +### E2E |
144 | 55 |
|
145 | | -- [Zeta] Support run the server through daemon mode (#4161) |
146 | | -- [Zeta] Change ClassLoader To Improve the SDK compatibility of the client (#4447) |
147 | | -- [Zeta] Client Support Async Submit Job (#4456) |
148 | | -- [Zeta] Add more detailed log output. (#4446) |
149 | | -- [Zeta] Improve seatunnel-cluster.sh (#4435) |
150 | | -- [Zeta] Reduce CPU Cost When Task Not Ready (#4479) |
151 | | -- [Zeta] Add parser log (#4485) |
152 | | -- [Zeta] Remove redundant code (#4489) |
153 | | -- [Zeta] Remove redundancy code in validateSQL (#4506) |
154 | | -- [Zeta] Improve JobMetrics fetch performance (#4467) |
155 | | -- [Zeta] Reduce the operation count of imap_running_job_metrics (#4861) |
156 | | -- [Zeta] Speed up listAllJob function (#4852) |
157 | | -- [Zeta] async execute checkpoint trigger and other block method (#4846) |
158 | | -- [Zeta] Reduce the number of IMAPs used by checkpointIdCounter (#4832) |
159 | | -- [Zeta] Cancel pipeline add retry to avoid cancel failed. (#4792) |
160 | | -- [Zeta] Improve Zeta operation max count and ignore NPE (#4787) |
161 | | -- [Zeta] Remove serialize(deserialize) cost when use shuffle action (#4722) |
162 | | -- [zeta] Checkpoint exception status messages exclude state data (#5547) |
163 | | -- [Zeta] Remove assert key words (#5947) |
| 56 | +- [Improve][Improve] Enable fakesource e2e of spark/flink (#7325) (#460e73ec3) |
| 57 | +- [Improve][Improve] Enable JdbcPostgresIdentifierIT (#7326) (#f6a1e51b8) |
| 58 | +- [Improve][Improve] Support windows for the e2e of paimon (#7329) (#a4db64d7c) |
164 | 59 |
|
165 | 60 | ## Feature |
166 | 61 |
|
167 | | -### Core |
| 62 | +### Connector-V2 |
168 | 63 |
|
169 | | -- [Core] [API] Support convert strings as List<T> option (#4362) |
170 | | -- [Core] [API] Add copy method to Catalog codes (#4414) |
171 | | -- [Core] [API] Add options check before create source and sink and transform in FactoryUtil (#4424) |
172 | | -- [Core] [Shade] Add guava shade module (#4358) |
173 | | -- [Core] [Spark] Support SeaTunnel Time Type (#5188) |
174 | | -- [Core] [Flink] Support Decimal Type with configurable precision and scale (#5419) |
175 | | -- [Core] [API] Support hocon style declare row type in generic type (#6187) |
| 64 | +- [Feature][Aliyun SLS] add Aliyun SLS connector #3733 (#7348) (#527c7c7b5) |
| 65 | +- [Feature][Activemq] Added activemq sink (#7251) (#f0cefbeb4) |
176 | 66 |
|
177 | | -### Connector-V2 |
| 67 | +### Transforms-V2 |
178 | 68 |
|
179 | | -- [Connector-V2] [CDC] [SQLServer] Support multi-table read (#4377) |
180 | | -- [Connector-V2] [Kafka] Kafka source supports data deserialization failure skipping (#4364) |
181 | | -- [Connector-V2] [Jdbc] [TiDB] Add TiDB catalog (#4438) |
182 | | -- [Connector-V2] [File] Add file excel sink and source (#4164) |
183 | | -- [Connector-V2] [FILE-OBS] Add Huawei Cloud OBS connector (#4577) |
184 | | -- [Connector-v2] [Snowflake] Add Snowflake Source&Sink connector (#4470) |
185 | | -- [Connector-V2] [Pular] support read format for pulsar (#4111) |
186 | | -- [Connector-V2] [Paimon] Introduce paimon connector (#4178) |
187 | | -- [Connector V2] [Cassandra] Expose configurable options in Cassandra (#3681) |
188 | | -- [Connector V2] [Jdbc] Supports GEOMETRY data type for PostgreSQL (#4673) |
189 | | -- [Connector V2] [Jdbc] Supports Kingbase database (#4803) |
190 | | -- [Transform-V2] Add UDF SPI and an example implement for SQL Transform plugin (#4392) |
191 | | -- [Transform-V2] Support copy field list (#4404) |
192 | | -- [Transform-V2] Add support CatalogTable for FieldMapperTransform (#4423) |
193 | | -- [Transform-V2] Add CatalogTable support for ReplaceTransform (#4411) |
194 | | -- [Transform-V2] Add Catalog support for FilterRowKindTransform (#4420) |
195 | | -- [Transform-V2] Add support CatalogTable for FilterFieldTransform (#4422) |
196 | | -- [Transform-V2] Add catalog support for SQL Transform plugin (#4819) |
197 | | -- [Connector-V2] [Assert] Support check the precision and scale of Decimal type (#6110) |
198 | | -- [Connector-V2] [Assert] Support field type assert and field value equality assert for full data types (#6275) |
199 | | -- [Connector-V2] [Iceberg] Support iceberg sink #6198 |
200 | | -- [Connector-V2] [FILE-OBS] Add Huawei Cloud OBS connector #4578 |
| 69 | +- [Feature] Split transform and move jar into connectors directory (#7218) (#d46cf16e5) |
| 70 | +- [Feature][LLM] Add LLM transform (#7303) (#855254e73) |
| 71 | +- [Feature][SQL] Support cast to bytes function of sql (#7284) (#b9acb573b) |
201 | 72 |
|
202 | | -### Zeta(ST-Engine) |
| 73 | +## Docs |
| 74 | + |
| 75 | +- [Docs] Change deprecated connector name in setup.md (#7366) (#862e2055c) |
| 76 | +- [Docs] Fix username parameter error in sftp sink document (#7334) (#191d9e18b) |
| 77 | +- [Docs] fix document configuration is rectified when the oss is selected as the checkpoint base (#7332) (#a12786b82) |
| 78 | +- [Docs] Fix miss sink-options-placeholders.md in sidebars (#7310) (#c94ea325b) |
| 79 | +- [Docs] Update Oracle-CDC.md (#7285) (#9d56cc33b) |
| 80 | +- [Docs] Fix hybrid cluster deployment document display error (#7306) (#2fd4eec22) |
| 81 | +- [Docs] translate event-listener doc into chinese (#7274) (#ec1c3198b) |
| 82 | + |
| 83 | +## Others |
| 84 | + |
| 85 | +- Bump org.apache.activemq:activemq-client (#7323) (#e23e3ac4e) |
| 86 | +- [Improve] Remove unused code (#7324) (#7c3cd99e0) |
| 87 | +- [Improve] Update snapshot version to 2.3.7 (#7305) (#4f120ff34) |
203 | 88 |
|
204 | | -- [Zeta] Support for mixing Factory and Plugin SPI (#4359) |
205 | | -- [Zeta] Add get running job info by jobId rest api (#4140) |
206 | | -- [Zeta] Add REST API To Get System Monitoring Information (#4315) |
207 | | -- [Transform V2 & Zeta] Make SplitTransform Support CatalogTable And CatalogTable Evolution (#4396) |
208 | | -- [Zeta] Move driver into lib directory and change operation count (#4845) |
209 | | -- [Zeta] Add Metaspace size default value to config file (#4848) |
210 | | -- [Zeta] Reduce the frequency of fetching data from imap (#4851) |
211 | | -- [Zeta] Add OSS support for Imap storage to cluster-mode type (#4683) |
212 | | -- [Zeta] Improve local mode startup request ports (#4660) |
213 | | - |
214 | | -## Docs |
215 | | - |
216 | | -- [Docs] Optimizes part of the Doris and SelectDB connector documentation (#4365) |
217 | | -- [Docs] Fix docs code style (#4368) |
218 | | -- [Docs] Update jdbc doc and kafka doc (#4380) |
219 | | -- [Docs] Fix max_retries default value is 0. (#4383) |
220 | | -- [Docs] Fix markdown syntax (#4426) |
221 | | -- [Docs] Fix Kafka Doc Error Config Key "kafka." (#4427) |
222 | | -- [Docs] Add Transform to Quick Start v2 (#4436) |
223 | | -- [Docs] Fix Dockerfile and seatunnel-flink.yaml in Set Up with Kubernetes (#4788) |
224 | | -- [Docs] Fix Mysql sink format doc (#4800) |
225 | | -- [Docs] Add the generate sink sql parameter for the jdbc sink document (#4797) |
226 | | -- [Docs] Add the generate sink sql parameter And example (#4769) |
227 | | -- [Docs] Redshift add defaultRowFetchSize (#4616) |
228 | | -- [Docs] Refactor connector-v2 docs using unified format Mysql (#4590) |
229 | | -- [Docs] Add Value types in Java to Schema features (#5087) |
230 | | -- [Docs] Replace username by user in the options of FtpFile (#5421) |
231 | | -- [Docs] Add how to configure logging related parameters of SeaTunnel-E2E Test (#5589) |
232 | | -- [Docs] Remove redundant double quotation mark from an example code (#5845) |
233 | | -- [Docs] Add Hive JDBC reference value (#5882) |
0 commit comments