你好: 这个问题我也遇到过,这是因为相关的依赖没有起作用,建议你重新启动一下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/
