插件版本

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并行度异常导致语法检查报错问题修复