是的,我代码贴错了, 你参考下下面的链接
> 在 2020年6月12日,11:55,Zhou Zach <[email protected]> 写道:
>
> 感谢回复,不过,根据文档
> 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)
>>