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
日常的跑批任务，加权内存使用量激增，并且长时间未跑通后触发query_time_out后被取消。
1 answers
doris ipv6部署出错
1 answers
Stream Load 出现Total file size will exceed limit 1073741824
1 answers
doris2.1.7在k8s中执行insert into 会将be全部搞挂
1 answers
重启BE会影响Routine Load吗？
1 answers
Doris2.1.7版本在使用JDBC类型的catalog遇到数据源大小写一致表名无法处理的问题
1 answers