Re: flink TableEnvironment can not call getTableEnvironment api

2020-06-11 文章 Leonard Xu
是的,我代码贴错了, 你参考下下面的链接 > 在 2020年6月12日,11:55,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" 写道: >> Hi, >>

Re:Re: flink TableEnvironment can not call getTableEnvironment api

2020-06-11 文章 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" 写道: >Hi, >这个文档应该是1.9时更新漏掉了,我建个issue修复下。现在可以这样使用[1]: >StreamExecutionEnvironment env =

Re: flink TableEnvironment can not call getTableEnvironment api

2020-06-11 文章 Leonard Xu
Hi, 这个文档应该是1.9时更新漏掉了,我建个issue修复下。现在可以这样使用[1]: StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings envSettings = EnvironmentSettings.newInstance() .useOldPlanner() .inStreamingMode() .build(); StreamTableEnvironment

flink TableEnvironment can not call getTableEnvironment api

2020-06-11 文章 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 =