DTStack / DTStack/flinkStreamSQL

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

Aperta
#420 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
Java
Stelle
2k
Fork
913
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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"问题;

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.