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
