You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Zhou Zach <wa...@163.com> on 2020/06/12 03:39:41 UTC
flink TableEnvironment can not call getTableEnvironment api
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)
Re: flink TableEnvironment can not call getTableEnvironment api
Posted by Leonard Xu <xb...@gmail.com>.
是的，我代码贴错了， 你参考下下面的链接
> 在 2020年6月12日，11:55，Zhou Zach <wa...@163.com> 写道：
>
> 感谢回复，不过，根据文档
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/joins.html
> 只能用Blink planner吧
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-06-12 11:49:08，"Leonard Xu" <xb...@gmail.com> 写道：
>> 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 <wa...@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)
>>
Re:Re: flink TableEnvironment can not call getTableEnvironment api
Posted by Zhou Zach <wa...@163.com>.
感谢回复，不过，根据文档
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/joins.html
只能用Blink planner吧
在 2020-06-12 11:49:08，"Leonard Xu" <xb...@gmail.com> 写道：
>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 <wa...@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)
>
Re: flink TableEnvironment can not call getTableEnvironment api
Posted by Leonard Xu <xb...@gmail.com>.
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 <wa...@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)