开发者社区> 问答> 正文

flink-cdc-mysql 使用时遇到的问题,求解答

我的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 代码如下:

请各位大佬帮帮孩子吧。。。。*来自志愿者整理的flink

展开
收起
雪哥哥 2021-12-05 12:52:04 746 0
1 条回答
写回答
取消 提交回答
  • 这个问题我也遇到过,这是因为相关的依赖没有起作用,建议你重新启动一下Flink集群希望对你有帮助。*来自志愿者整理的flink

    2021-12-05 17:58:42
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
基于 Flink CDC 打造 企业级实时数据集成方案 立即下载
李劲松|Flink Table Store 典型应用场景 立即下载