1.8.2
版本发布时间: 2020-02-22 14:29:24
DTStack/flinkStreamSQL最新发布版本:r1.8.7(2020-07-15 15:57:09)
- 对Kakfa插件进行了公共代码抽取，支持通过scheam的方式解析kafka avro,json,csv数据格式。
- 移除了launcher模块无用代码。
- 内部支持对回溯流的重新注册，以及关系型数据库中对回溯流采用删除或者追加的模式。
- 对RDB SINK模块代码进行重构，对部分插件支持数据部分替换和全部替换两种插入语句。
- 支持维表的谓词下推操作。
- 修复连续JOIN的BUG。