老師我的版本是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