DTStack / flinkStreamSQL

基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 923 forks source link

【2021-04-11】FlinkStreamSQL 更新记录 #420

Open FlechazoW opened 3 years ago

FlechazoW commented 3 years ago

1.[kudu][async] 修复kudu异步维表primary key 类型转化导致查询失败; 2.[core] 为了避免因为权限校验导致的任务失败,先将权限校验的默认值改为false; 3.[core] 修复脏数据在设置了remoteSqlPluginPath时任务提交失败,抛出找不到脏数据插件路径的异常; 4.[http] 解决http发送中文乱码; 5.[file] File source 增加脏数据的记录; 6.[dirty] 修改dirty plugins的插件地址参数,移除remoteSqlPlugin影响; 7.[http] 使用PoolingHttpClientConnectionManager来创建连接线程池; 8.[file] 优化File source 代码,移除location, hdfsSite, coreSite等不必要参数,调整FileSourceTableInfo的结构,将Csv、Json、Arvo等拆分为独立类; 9.[impala] fix String.replaceFirst中的坑,replaceFirst("\?", value),如果value中$后不是数字,那么会出现"illegal group reference:group index is missing"问题;