flink TableEnvironment can not call getTableEnvironment api

[Zhou Zach]

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)

[Leonard Xu]

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 <[hidden email]> 写道：
>
>
>
> 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)

[Zhou Zach]

感谢回复，不过，根据文档
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/joins.html
只能用Blink planner吧

















在 2020-06-12 11:49:08，"Leonard Xu" <[hidden email]> 写道：

>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 <[hidden email]> 写道：
>>
>>
>>
>> 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)
>

[Leonard Xu]

是的，我代码贴错了， 你参考下下面的链接

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