我的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/

回复