-
>发件人:"Leonard Xu"发送时间:2020年6月12日(星期五) 下午5:43
>收件人:"user-zh"
>主题:Re: flink sql Temporal table join failed
>
>
>
>
>你刚好踩到了这个坑，这是flink保留的关键字（time）转义的bug，1.10.1及之后的版本(即将发布的1.11)中修复了的。
>
>祝好
>Leonard Xu
>
> 在 2020年6月12日，17:38，Zhou Zach
>
??
https://lists.apache.org/thread.html/r951ca3dfa24598b2c90f9d2172d5228c4689b8a710d7dc119055c5d3%40%3Cuser-zh.flink.apache.org%3E
----
??:"Leonard Xu"http://www.slf4j.org/codes.html#multiple_bindings for an
explanation.
SLF4J:
感谢提醒
在 2020-06-12 17:43:20，"Leonard Xu" 写道：
>
>你刚好踩到了这个坑，这是flink保留的关键字（time）转义的bug，1.10.1及之后的版本(即将发布的1.11)中修复了的。
>
>祝好
>Leonard Xu
>
>> 在 2020年6月12日，17:38，Zhou Zach 写道：
>>
>>
>>
>>
>> 是的，1.10.0版本
>>
>>
>>
>>
>>
>>
>>
>>
>> 在 2020-06-12 16:28:15，"Benchao Li" 写道：
>>>
你刚好踩到了这个坑，这是flink保留的关键字（time）转义的bug，1.10.1及之后的版本(即将发布的1.11)中修复了的。
祝好
Leonard Xu
> 在 2020年6月12日，17:38，Zhou Zach 写道：
>
>
>
>
> 是的，1.10.0版本
>
>
>
>
>
>
>
>
> 在 2020-06-12 16:28:15，"Benchao Li" 写道：
>> 看起来你又踩到了一个坑，你用的是1.10.0吧？可以切换到1.10.1试一下，有两个bug已经在1.10.1中修复了。
>>
>> Zhou Zach
是的，1.10.0版本
在 2020-06-12 16:28:15，"Benchao Li" 写道：
>看起来你又踩到了一个坑，你用的是1.10.0吧？可以切换到1.10.1试一下，有两个bug已经在1.10.1中修复了。
>
>Zhou Zach 于2020年6月12日周五 下午3:47写道：
>
>> 还是不行，
>> SLF4J: Class path contains multiple SLF4J bindings.
>> SLF4J: Found binding in
>>
看起来你又踩到了一个坑，你用的是1.10.0吧？可以切换到1.10.1试一下，有两个bug已经在1.10.1中修复了。
Zhou Zach 于2020年6月12日周五 下午3:47写道：
> 还是不行，
> SLF4J: Class path contains multiple SLF4J bindings.
> SLF4J: Found binding in
>
还是不行，
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/Zach/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.4.1/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
参考一下sql相关time的文档，根据描述使用姿势有问题：https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/time_attributes.html
At 2020-06-12 14:24:07, "Zhou Zach" wrote:
>flink 1.10.0:
>在create table中，加PROCTIME() AS proctime字段报错
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>在 2020-06-12 14:08:11，"Benchao Li"
你写反了，是proctime AS PROCTIME()。
计算列跟普通query里面的AS是反着的。
Zhou Zach 于2020年6月12日周五 下午2:24写道：
> flink 1.10.0:
> 在create table中，加PROCTIME() AS proctime字段报错
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-06-12 14:08:11，"Benchao Li" 写道：
> >Hi，
> >
> >Temporal Table
需要使用Proctime才可以关联，参考：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sql/create.html
> 在 2020年6月12日，下午2:24，Zhou Zach 写道：
>
> flink 1.10.0:
> 在create table中，加PROCTIME() AS proctime字段报错
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>> 在 2020-06-12 14:08:11，"Benchao
flink 1.10.0:
在create table中，加PROCTIME() AS proctime字段报错
在 2020-06-12 14:08:11，"Benchao Li" 写道：
>Hi，
>
>Temporal Table join的时候需要是处理时间，你现在这个b.`time`是一个普通的时间戳，而不是事件时间。
>可以参考下[1]
>
>[1]
>https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html
Hi，
Temporal Table join的时候需要是处理时间，你现在这个b.`time`是一个普通的时间戳，而不是事件时间。
可以参考下[1]
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html
Zhou Zach 于2020年6月12日周五 下午1:33写道：
> SLF4J: Class path contains multiple SLF4J bindings.
>
> SLF4J: Found binding in
>
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/Zach/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.4.1/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
13 matches
Mail list logo
