大佬们好 我的环境是:
| 组件 | 版本 | | Flink | 1.12 | | Kafka | 2.5.0 | | Zookeeper | 3.6.0 | 完整代码是 https://paste.ubuntu.com/p/pRWpvJw4b8/ kafka消费端(使用命令行消费)确认有数据输出。 但是上述代码没有输出,DDL检查过确认无误。 因为听说executeSql会提交任务,所以把最后一句execute给注销了。 求问应该如何修改代码才能让代码有输出? 谢谢
大佬们好 我的环境是:
| 组件 | 版本 | | Flink | 1.12 | | Kafka | 2.5.0 | | Zookeeper | 3.6.0 | 完整代码是 https://paste.ubuntu.com/p/pRWpvJw4b8/ kafka消费端(使用命令行消费)确认有数据输出。 但是上述代码没有输出,DDL检查过确认无误。 因为听说executeSql会提交任务,所以把最后一句execute给注销了。 求问应该如何修改代码才能让代码有输出? 谢谢