基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
1、新增hbaes结果表和维表Kerberos功能 2、redis 结果表的数据结构调整和维表的数据结构一致 3、其他bug修复
1、新增tidb维表和结果表的功能 2、新增oceanbase维表和结果表的功能 3、修复rdb维表的资源泄漏bug 4、其他部分bug修复和代码优化
1、更新插件文档,补充示例说明 2、对内部代码做规范调整 3、对异步维表逻辑做了抽象复用 4、对rdb异步维表新增连接重试和反压功能 5、对现有的问题进行修复
flink版本升级为1.10
1.修复新版SQL解析相关Bug. 2.修复解析维表时间字段BUG. 3.代码规范处理 4.重构文档
本次更新主要是解决流与维表混合join bug; 当前版本流与维表join 之后无需添加别名 eg:streamA join dimA join steamB join streamC
遗留问题:
基于flink1.5 的稳定版本