wormhole-0.5.1-beta release 更新
wormhole-0.5.1-beta release更新, 欢迎下载试用~~
链接:https://pan.baidu.com/s/1rRAXOvGLG8KyKjqGCkRGwA 密码:gcqs
wormhole用户手册https://edp963.github.io/wormhole
注意:升级至0.5.1-beta版本,须将Kafka版本由0.10.0.0升级至0.10.2.2,0.10.2.2以上版本须自行测试
具体步骤及使用步骤请参考用户手册
新功能:
(1)flinkx支持多种sink,包括cassandra/oracle/mysql/vertica/es/hbase/kafka/kudu/mongodb/phoenix
(2)flinkx支持用户自定义数据格式ums_extension
(3)flinx cep支持设置event time(使用ums_ts_时间,原只支持processing time)
(4)解决flink sql的where条件不生效问题
(5)一些小问题调整等