老师我的版本是1.9.1 是这种 没有tEnv.registerDataStream
tEnv.registerDataStreamInternal("books",map);
tEnv.registerDataStreamInternal("books",map);
2020-01-09
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