wormhole-0.6.3 release 更新
wormhole-0.6.3 release更新, 欢迎下载试用~~
链接:https://pan.baidu.com/s/1nDzcHYKIVCT6atq9wAuK9Q 密码:5cqn
wormhole用户手册https://edp963.github.io/wormhole
Release Notes:
【Improvement】
(1)flinkx event time添加时间延迟配置
(2)flinkx优化checkpoint配置方式,可对每个flow配置是否启用checkpoint
(3)sink kafka异步模式修改为同步模式
(4)支持sink hbase设置版本字段进行幂等
(5)增加sink kudu表中表名带"."等特殊字符的支持
(6)sparkx lookup kudu sql常量条件支持
(7)支持lookup关系型数据库不关联流上数据
(8)sparkx优化custom class transform接口,并增加带参数的transform接口
(9)sparkx支持消费不带key的kafka消息
(10)oracle支持NVARCHAR2类型
(11)sparkx优化feedback error消息格式和内容
(12)适配kerberos认证和无kerberos认证的kafka数据源
(13)优化修改kill spark client pid方式
【Fix Bugs】
(1)修复sink kudu date类型为null bug
(2)修复落csv bug
(3)修复sink es datatime类型丢0 bug
(4)修复feedback mysql bug
(5)修复lookup BLOB类型bug
(6)修复非HA hadoop集群落hdfslog bug
(7)修复job sink config和snapshot bug
注意:升级至0.6.3版本,需执行以下操作
具体部署及使用步骤请参考用户手册https://edp963.github.io/wormhole/deployment.html
(1)如果有使用custom class,需要按照新接口修改使用的custom class
(2)数据库更新请参考用户手册