你好:
你使用的是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
你好 :
图片是看不到的,建议直接粘贴文本再发送一次
chengyanan1...@foxmail.com
发件人: 阿华田
发送时间: 2020-08-07 13:49
收件人: user-zh
主题: flink1.11 DDL定义kafka source报错
代码如下
阿华田
a15733178...@163.com
签名由 网易邮箱大师 定制
错误信息:
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
代码如下
| |
阿华田
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制