使用flink sql cli读取postgres-cdc时，Could not find any factory for identifier 'postgres-cdc' that implements 'org.apache.flink.table.factories.DynamicTableSinkFactory' in the classpath.

Wed, 09 Dec 2020 00:49:06 -0800 

在使用standalone模式，并启动sql
cli后，报错如下。但是我的lib目录是引入了flink-sql-connector-postgres-cdc-1.1.0.jar,
并且重启过集群。同样方式使用mysql cdc是可以的。

Caused by: org.apache.flink.table.api.ValidationException: Could not find
any factory for identifier 'postgres-cdc' that implements
'org.apache.flink.table.factories.DynamicTableSinkFactory' in the classpath.

Available factory identifiers are:

blackhole
jdbc
kafka
print
-----------------------------------------------

所以我是那里没配置对？







--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复