Re: 回复:flink1.11 DDL定义kafka source报错

2020-08-07 文章 chengyanan1...@foxmail.com
你好: 你使用的是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

回复:flink1.11 DDL定义kafka source报错

2020-08-07 文章 阿华田
错误信息: 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