感谢回复，不过，根据文档 https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/joins.html 只能用Blink planner吧
在 2020-06-12 11:49:08，"Leonard Xu" <[email protected]> 写道： >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 <[email protected]> 写道： >> >> >> >> 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) >
