开发者社区 问答 正文

Flink读取kafka没有报错也没有数据输出,Kafka消费端有数据,怎么解决?谢谢

我的环境是: 

| 组件 | 版本 |  |  Flink  |  1.12  |  |  Kafka  |  2.5.0  |  |  Zookeeper  |  3.6.0  | 

完整代码是  https://paste.ubuntu.com/p/pRWpvJw4b8/  kafka消费端(使用命令行消费)确认有数据输出。  但是上述代码没有输出,DDL检查过确认无误。 

因为听说executeSql会提交任务,所以把最后一句execute给注销了。  求问应该如何修改代码才能让代码有输出?  谢谢*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:47:11 1323 分享
分享
版权
举报
0 条回答
写回答
取消 提交回答