使用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.

[王敏超]

在使用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/

[zhisheng]

sql client 也得重启

王敏超 <[hidden email]> 于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/
>

[Jark]

postgres-cdc 的表只支持读，不支持写。

On Wed, 9 Dec 2020 at 22:49, zhisheng <[hidden email]> wrote:

> sql client 也得重启
>
> 王敏超 <[hidden email]> 于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/
> >
>