flinkcdc pgsqlcdc到doris报错

Viewed 38
2.1

doris 2.1.4
flink 1.19.1
image.png
image.png
image.png
sql-client提交
image.png

1 Answers
  1. Flink CDC 从3.1.x，改了包名 。当前的flink-connector-doris是基于flink cdc 2.4.2 ，可以考虑在lib下面放入以下包：https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-postgres-cdc/2.4.2
vinlee303
Related Questions
doris集群部署重启报错
doris2.1.9, fe和be的这些错误日志有影响没?
[2.1.9] 域名形式的 admin 用户无法删除
发送奔溃直接退出
docker compose 3个节点部署 3fe3be 启动是吧
1 answers
PipelineX 引擎，多BE节点环境下，由于fragment内部 local exchange的拆分，local shuffle 数据分发出现错乱，导致SQL结果错误。
1 answers