postgres-cdc 的表只支持读，不支持写。 On Wed, 9 Dec 2020 at 22:49, zhisheng <[email protected]> wrote:
> sql client 也得重启 > > 王敏超 <[email protected]> 于2020年12月9日周三 下午4:49写道： > > > 在使用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/ > > >
