flink cdc 连接问题之连接报错如何解决

问题一：Flink CDC里为啥没反应？没输出？

Flink CDC里为啥没反应？没输出？

参考回答：

改依赖 还有表名前面要加上schema名。

关于本问题的更多回答可点击原文查看：

https://developer.aliyun.com/ask/596290?spm=a2c6h.13066369.question.16.283f3f33NppbZ7

问题二：flink cdc 3.0 cli 必须指定sink 表名吗？

flink cdc 3.0 cli 必须指定sink 表名吗， route 中的 sink-table 不能使用正则吗?其实就是想把目标库的名称变一下，比如： source-table: test.. , sink-table : ods_test..。

参考回答：

yaml不行，需要对接官方的connector可以。后面会支持的。

关于本问题的更多回答可点击原文查看：

https://developer.aliyun.com/ask/596285?spm=a2c6h.13066369.question.17.283f3f33IXnhwS

问题三：Flink CDCsql-cli 支持application吗？没有catalog就不能恢复任务吗？

Flink CDC里sql-cli 支持application吗？没有catalog就不能恢复任务吗？配置到hive不可以吗？

参考回答：

这个你找个开发平台提交任务就行了，cli重启就没有catlog了。

关于本问题的更多回答可点击原文查看：

https://developer.aliyun.com/ask/596262?spm=a2c6h.13066369.question.18.283f3f33Ci2Zv5

问题四：flink cdc 读pgsql 的java代码怎么写？

flink cdc 读pgsql 的java代码怎么写？

参考回答：

可以参考这个文档：

https://ververica.github.io/flink-cdc-connectors/master/content/quickstart/datastream-api-package-guidance.html

关于本问题的更多回答可点击原文查看：

https://developer.aliyun.com/ask/596253?spm=a2c6h.13066369.question.19.283f3f33dD0jzA

问题五：flink cdc 可以在flink-sql cli里面使用吗？报错如下怎么办？

flink cdc 可以在flink-sql cli里面使用吗？报错如下怎么办？ 要用这个包吗？

参考回答：

pipeline连接器不支持早sql-client界面使用，但是你可以用原来的sql-xxxx连接器。

关于本问题的更多回答可点击原文查看：

https://developer.aliyun.com/ask/596240?spm=a2c6h.13066369.question.20.283f3f33b3ZjJt