postgres-cdc 的表只支持读,不支持写。
On Wed, 9 Dec 2020 at 22:49, zhisheng wrote:
> sql client 也得重启
>
> 王敏超 于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
sql client 也得重启
王敏超 于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
在使用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.DynamicTableS