![file](https://img2023.cnblogs.com/other/3195851/202306/3195851-20230625185718639-2144905227.jpg) > 近日,Apache SeaTunnel 正式發佈 2.3.2 版本。此時距離上一版本 2.3.1 ...
近日,Apache SeaTunnel 正式發佈 2.3.2 版本。此時距離上一版本 2.3.1 發佈已有兩個多月,期間我們收集並根據用戶和開發者的反饋,在 2.3.2 版本中對 SeaTunnel Zeta Engine 進行了 Bug 修複,提高了引擎的穩定性和使用效率。
此外,新版本還對 Connector-V2 中的連接器進行了功能和性能優化,同時 SQL Transfrom 支持了自定義 UDF 函數,Zeta Engine 也提供了通過 Rest API 的方式進行集群的監控和查詢操作。
本文將為大家介紹 Apache SeaTunnel 2.3.2 版本更新內容具體情況。
- Release Note: https://github.com/apache/seatunnel/blob/2.3.2-release/release-note.md
- 下載地址:https://seatunnel.apache.org/download
新功能
本次更新,Zeta Engine 支持了以 RestAPI 的方式獲取任務和系統的監控信息,用戶可以通過調用 HTTP 請求到任意節點完成數據信息請求,增強了任務的監控能力。
詳情可參考:https://seatunnel.apache.org/docs/2.3.2/seatunnel-engine/rest-api
此外,2.3.2 版本中 SQL Transform 支持了自定義 UDF 函數,詳細用法請參考:https://seatunnel.apache.org/docs/2.3.2/transform-v2/sql-udf
Core
[Core] [API] 支持將字元串轉換為List
[Core] [API] 在創建源、接收器和轉換之前添加選項檢查到FactoryUtil中 (#4424)
[Core] [Shade] 添加guava shade模塊 (#4358)
Connector-V2
- [Connector-V2] [CDC] [SQLServer] 支持多表讀取 (#4377)
- [Connector-V2] [Kafka] Kafka源支持跳過數據反序列化失敗 (#4364)
- [Connector-V2] [Jdbc] [TiDB] 添加了TiDB目錄 (#4438)
- [Connector-V2] [File] 添加了文件Excel的源和接收器 (#4164)
- [Transform-V2] 添加了UDF SPI和一個示例實現,用於SQL轉換插件 (#4392)
- [Transform-V2] 支持複製欄位列表 (#4404)
- [Transform-V2] 為FieldMapperTransform添加了CatalogTable支持 (#4423)
- [Transform-V2] 為ReplaceTransform添加了CatalogTable支持 (#4411)
- [Transform-V2] 為FilterRowKindTransform添加了Catalog支持 (#4420)
- [Transform-V2] 為FilterFieldTransform添加了CatalogTable支持 (#4422)
Zeta Engine
- [Zeta] 支持Factory和Plugin SPI的混合使用 (#4359)
- [Zeta] 添加了通過作業ID獲取運行中作業信息的REST API (#4140)
- [Zeta] 添加了獲取系統監控信息的REST API (#4315)
- [Transform V2 & Zeta] 使SplitTransform支持CatalogTable和CatalogTable演化 (#4396)
改進
Apache SeaTunnel 2.3.2 版本對 Zeta 引擎進行了穩定性修複,解決了記憶體占用過高不釋放的問題,同時解決了大量資源占用問題,對性能也做了相應的優化。
Core
- [Core] [Spark] 將轉換操作從Spark Driver推送到Executors (#4503)
- [Core] [Starter] 優化代碼結構,刪除冗餘代碼 (#4525)
- [Core] [Translation] [Flink] 優化代碼結構,刪除冗餘代碼 (#4527)
Connector-V2
- [Connector-V2] [CDC] 改進startup.mode/stop.mode選項 (#4360)
- [Connector-V2] [CDC] 優化jdbc fetch-size選項 (#4352)
- [Connector-V2] [SQLServer] 修複了SQL Server目錄的問題 (#4441)
- [Connector-V2] [StarRocks] 改進StarRocks序列化錯誤消息 (#4458)
- [Connector-V2] [Jdbc] 添加了SQL日誌,並更新了一些樣式 (#4475)
- [Connector-V2] [Jdbc] 修複了多個表時無法自動獲取表名的問題 (#4514)
- [Connector-V2] [S3 & Kafka] 刪除不可用的S3和Kafka目錄 (#4477)
- [Connector-V2] [Pulsar] 支持Canal格式
Zeta Engine
- [Zeta] 支持通過守護進程模式運行伺服器 (#4161)
- [Zeta] 使用ClassLoader改進客戶端的SDK相容性 (#4447)
- [Zeta] 客戶端支持非同步提交作業 (#4456)
- [Zeta] 增加更詳細的日誌輸出 (#4446)
- [Zeta] 改進seatunnel-cluster.sh腳本 (#4435)
- [Zeta] 當任務未準備好時,降低CPU消耗 (#4479)
- [Zeta] 添加解析器日誌 (#4485)
- [Zeta] 刪除冗餘代碼 (#4489)
- [Zeta] 在validateSQL中刪除冗餘代碼 (#4506)
- [Zeta] 改進JobMetrics的性能 (#4467)
Bug修複
Core
*[Core] [API] 修複了列表的通用類丟失的問題 (#4421)
*[Core] [API] 修複瞭解析嵌套行數據類型鍵變為大寫的問題 (#4459)
Connector-V2
- [Json-format] [Canal-Json] 修複了JSON反序列化時的空指針異常問題 (#4195)
- [Connector-V2] [Jdbc] 修複了在JDBC源查詢中不支持欄位別名的問題 (#4210)
- [Connector-V2] [Jdbc] 修複了連接超時導致連接失敗的問題 (#4322)
- [Connector-V2] [Jdbc] 將JdbcOption: generate_sink_sql的預設值設置為false (#4471)
- [Connector-V2] [Pulsar] 修複了無法持續消費消息的問題 (#4125)
- [Connector-V2] [Eleasticsearch] 修複了文檔描述錯誤的問題 (#4390)
- [Connector-V2] [Eleasticsearch] 修複了源反序列化錯誤和不適當的問題 (#4233)
- [Connector-V2] [Kafka] 修複了KafkaProducer資源從未被釋放的問題 (#4302)
- [Connector-V2] [Kafka] 修複了client.id導致許可權問題的問題 (#4246)
- [Connector-V2] [Kafka] 修複了提交偏移錯誤導致KafkaConsumerThread退出的問題 (#4379)
Zeta Engine
- [Zeta] 修複了LogicalDagGeneratorTest測試用例的問題 (#4401)
- [Zeta] 修複了MultipleTableJobConfigParser僅解析一個轉換的問題 (#4412)
- [Zeta] 修複了缺少common插件jar包的問題 (#4448)
- [Zeta] 修複了在檢查點已完成時仍調用handleCheckpointError的問題 (#4442)
- [Zeta] 修複了作業錯誤消息不正確的bug (#4463)
- [Zeta] 修複了查找TaskGroup部署節點的bug (#4449)
- [Zeta] 修複了配置文件的bug (#4488)
- [Zeta] 修複了從zeta載入連接器的邏輯問題 (#4510)
- [Zeta] 修複了hadoop-hdfs的衝突依賴問題 (#4509)
E2E
*[E2E] [Kafka] 修複了Kafka端到端測試用例的問題 (#4520)
*[Container Version] 修複了無法重現的測試用例風險問題 #4591
文檔優化
- [Docs] 優化了Doris和SelectDB連接器文檔的部分內容 (#4365)
- [Docs] 修複了文檔中的代碼樣式問題 (#4368)
- [Docs] 更新了jdbc文檔和kafka文檔 (#4380)
- [Docs] 修複了max_retries預設值為0的問題 (#4383)
- [Docs] 修複了Markdown語法問題 (#4426)
- [Docs] 修複了Kafka文檔錯誤的配置鍵 "kafka." (#4427)
- [Docs] 添加了快速入門v2中的Transform部分 (#4436)
貢獻者名單
感謝白鯨開源工程師 範佳 對本次版本發佈的支持,以及以下社區小伙伴的貢獻!
Andrew Wetmore,
Bibo,
Carl-Zhou-CN,
Cason-ACE,
Chengyu Yan,
CodingGPT,
dalong,
Eric,
FlechazoW,
Guangdong Liu,
Hao Xu,
J.A.R.V.I.S,
Kim,
Laglangyue,
Marvin,
TaoZex,
Tyrantlucifer,
Xiaojian Sun,
ZhilinLi,
Zongwen Li,
dylandai,
gnehil,
hailin0,
ic4y,
kezhenxu94,
lightzhao,
lucklilili,
lvshaokang,
mengxiaopeng,
monster,
songjianet,
stdnt-xiao,
thomasc,
will27,
wyc,
xiaofan2012,
zhilinli,
沫
本文由 白鯨開源 提供發佈支持!