06:14
我目前在使用 flink1.9.0,代码第23行这里,不能这么用了,会报错。
首先IDEA会提示 getTableEnvironment 这个方法不存在。
查了官方的文档:https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/common.html#create-a-tableenvironment
正确的写法应该是这样的:
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
然后程序执行成功了
我目前在使用 flink1.9.0,代码第23行这里,不能这么用了,会报错。
首先IDEA会提示 getTableEnvironment 这个方法不存在。
查了官方的文档:https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/common.html#create-a-tableenvironment
正确的写法应该是这样的:
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
然后程序执行成功了
2019-11-07
最赞回答 / 请用手机端下载视频
org.apache.flink.api.scala.ExecutionEnvironment这个类是scala版本的批处理api包,你需要引入依赖flink-scala_2.11
2019-06-28
最赞回答 / 浊酒劣马江湖儿女
https://github.com/apache/flink/tree/master/flink-examples/flink-examples-table
2019-06-28