你好:
你使用的是Flink 1.11版本,但是你的建表语句还是用的老版本,建议更换新版本的建表语句后再试一下
参考如下:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html
chengyanan1...@foxmail.com
发件人: 阿华田
发送时间: 2020-08-07 14:03
收件人: user-zh@flink.apache.org
主题: 回复:flink1.11 DDL定义kafka
错误信息:
Exception in thread "main" java.lang.IllegalStateException: No operators
defined in streaming topology. Cannot generate StreamGraph.
at
org.apache.flink.table.planner.utils.ExecutorUtils.generateStreamGraph(ExecutorUtils.java:47)
at