你好:
 这个问题我也遇到过,这是因为相关的依赖没有起作用,建议你重新启动一下Flink集群。



 
发件人: zapjone
发送时间: 2020-10-31 10:34
收件人: user-zh
主题: Re: flink-cdc-mysql 使用时遇到的问题
感觉是不是表的权限没有开哦?
 
Sent from my iPhone
 
> On Oct 31, 2020, at 10:07, yangxusun9 <[email protected]> wrote:
> 
> 我的flink/lib下的文件列表如下
> <http://apache-flink.147419.n8.nabble.com/file/t1061/flink_lib.png> 
> 当我使用flink-sql client 时,查询表报错如下
> <http://apache-flink.147419.n8.nabble.com/file/t1061/flink_sql_client_error.png>
>  
> 
> 而当我尝试使用API来测试时,同样遇到了一个bug,Caused by:
> org.apache.kafka.connect.errors.ConnectException: Encountered change event
> for table test.order_info whose schema isn't known to this connector
> 代码如下:
> 
> 
> 请各位大佬帮帮孩子吧。。。。
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
 
 

回复