flinkcdc pgsqlcdc到doris报错

Viewed 31

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