插件版本

plugin-3.8.0-1.1.0

平台最低版本

3.8.0

feature

  1. 插件包名称修改，带上了flink版本，scala版本，hive版本等很多信息，例如plugin_ne-flink-1.12.4-1.0.0_scala2.11_hive2.1.1-3.8.0-1.1.0.tar.gz
  2. 本地调试支持带主键的应用
  3. 1.12 ddl任务hdfs自动带上hive-conf-dir配置
  4. oracle连接器支持cblob和ncblob数据类型
  5. flink1.12的kudu连接器的支持
  6. flink1.12的hbase连接器的支持
  7. 支持任务通过set语句设置状态的TTL
  8. 支持sql任务的ddl以及元数据混编功能
  9. 支持解析错误的数据上报监控
  10. 老的kernel重构，新增插件服务，负责语法检查及debug功能
  11. flink1.12的memory连接器的支持
  12. 支持任务通过set语法设置时区
  13. 支持计算列的功能
  14. flink1.12的redis连接器的支持
  15. 的http连接器的支持
  16. 1.12内核加上了kafka延迟监控的功能
  17. flink1.10的hbase连接器支持kerberos认证
  18. jdbc连接器支持两个参数connector.key-fields和connector.sharding-fields

bugfix

  1. 元数据中心mysql 作为dim表，表中包含timestamp时报错
  2. 解决元数据中心因timestamp字段精度不足的问题
  3. 支持V2版本的并行度设置
  4. 修复decimal(38,10)类型异常
  5. 修复debug功能的几个重要bug