是的,我代码贴错了, 你参考下下面的链接
> 在 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,
>>
感谢回复,不过,根据文档
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 =
Hi,
这个文档应该是1.9时更新漏掉了,我建个issue修复下。现在可以这样使用[1]:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings envSettings = EnvironmentSettings.newInstance()
.useOldPlanner()
.inStreamingMode()
.build();
StreamTableEnvironment
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 =