你刚好踩到了这个坑,这是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 于2020年
是的,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
>> [jar:file:/Users/Zach/.m2/repository/org/
看起来你又踩到了一个坑,你用的是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
> [jar:file:/Users/Zach/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.4.1/log4j-slf4j-impl-2.4.1.jar!
还是不行,
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
[jar:file:/Users/Zach/.m2/repository/
你写反了,是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 join的时候需要是处理时间,你现在这个b.`time`是一个普通的时间戳,而不是事件时
需要使用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 L
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
> [