Re: flink sql Temporal table join failed

2020-06-12 文章 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" 写道: >> 看起来你又踩到了一个坑,你用的是1.10.0吧?可以切换到1.10.1试一下,有两个bug已经在1.10.1中修复了。 >> >> Zhou Zach

Re:Re: Re: Re: flink sql Temporal table join failed

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

Re: Re: Re: flink sql Temporal table join failed

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

Re:Re: Re: flink sql Temporal table join failed

2020-06-12 文章 Zhou Zach
还是不行, 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

Re: Re: flink sql Temporal table join failed

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

Re: flink sql Temporal table join failed

2020-06-12 文章 李奇
需要使用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

Re: flink sql Temporal table join failed

2020-06-12 文章 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 Zhou Zach 于2020年6月12日周五 下午1:33写道: > SLF4J: Class path contains multiple SLF4J bindings. > > SLF4J: Found binding in >