Hi, 这个文档应该是1.9时更新漏掉了,我建个issue修复下。现在可以这样使用[1]: StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings envSettings = EnvironmentSettings.newInstance() .useOldPlanner() .inStreamingMode() .build(); StreamTableEnvironment tableEnvironment = StreamTableEnvironment.create(env, envSettings);
Best, Leonard Xu [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#create-a-tableenvironment <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#create-a-tableenvironment> > 在 2020年6月12日,11:39,Zhou Zach <wander...@163.com> 写道: > > > > flink version 1.10.0 > > > 根据文档 > https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/temporal_tables.html#defining-temporal-table > 想要Defining Temporal Table,但是没有发现getTableEnvironment。。 > > > val env = StreamExecutionEnvironment.getExecutionEnvironment > val tEnv = TableEnvironment.getTableEnvironment(env)