大佬们好
我的环境是:

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




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


因为听说executeSql会提交任务,所以把最后一句execute给注销了。
求问应该如何修改代码才能让代码有输出?
谢谢

回复