插件版本

plugin-3.8.3-1.3.1

平台最低版本

3.8.3

  • 因3.8.3才开始支持Flink1.14,如仅使用flink旧的版本,可兼容至3.8.0

    feature

  1. 新增clickhouse connector,支持cdc消费、分布式写入优化等(1.12)
  2. 新增Protobuf format(1.12)
  3. 新增String format(1.12/1.14)
  4. 支持es、redis、clickhouse connector自定义sink并行度(1.12)
  5. 支持redis connector hincrBy操作(1.12/1.14)
  6. 优化lookup join缓存命中率、减少维表全量数据的缓存(1.12)
  7. 支持jdbc、hbase、hive维表缓存监控(1.12)
  8. 支持Arctic Catalog(1.12/1.14)
  9. 参数风格统一增强易用性,jdbc connector配置sink并行度调整为sink.parallelism,hbase connector lookup参数移除connector前缀(1.12/1.14)
  10. 支持canal-json/json开启忽略解析异常时,打印异常情况方便排查(1.12)
  11. 支持读取canal-json里的metadata字段(1.12)
  12. 支持checkpoint不开启,支持配置重启策略(平台3.9.0)

bugfix

  1. hdfs connector认证增加重试次数上限防止Stackoverflow
  2. 向metahub表插入空串异常修复
  3. jdbc connector并行度异常导致语法检查报错问题修复