flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benchao Li <libenc...@gmail.com>
Subject Re: flink-1.10-sql 维表问题
Date Thu, 16 Apr 2020 02:27:15 GMT
Hi,

你提到的这两个issue都是在1.10.1版本中才会修复,但是现在还没有release1.10.1版本。
你现在是用release-1.10 branch编译的么?
此外,是否方便也贴一下完整的DDL以及query呢?

111 <xinghalo@163.com> 于2020年4月16日周四 上午8:22写道:

> Hi,
> 更正一下,我的问题跟这个类似,遇到的问题也在评论中:
>
> https://issues.apache.org/jira/browse/FLINK-16345?jql=text%20~%20%22Caused%20by%3A%20java.lang.AssertionError%3A%20Conversion%20to%20relational%20algebra%20failed%20to%20preserve%20datatypes%3A%22
> Best,
> Xinghalo
>
>
> 在2020年04月16日 08:18,111<xinghalo@163.com> 写道:
> Hi,
> 我的时间字段就是proctime()产生的...因为当时有个time关键字的bug,所以按照这个confluence进行了修正。
> 后来使用时间字段的时候,就出了现在的问题。
> https://issues.apache.org/jira/browse/FLINK-16068
> Best,
> Xinghalo
>
>
> 在2020年04月15日 21:21,Benchao Li<libenchao@gmail.com> 写道:
> 这个原因是维表join的时候需要使用的时间是*有处理时间属性*[1]
的。
>
> [1]
>
> https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html
>
> 111 <xinghalo@163.com> 于2020年4月15日周三 下午9:08写道:
>
> Hi,
> 现在直接使用DDL声明可以正常使用吗?我这边使用的时候发现,FOR
SYSTEM_TIME AS OF o.proctime
> 会报类型不匹配问题…timestamp(3)和time attribute 不匹配.
>
>
> 所以现在只能使用connector内部提供的Lookup function手动注册成 table
function,使用lateral table
> xxx的语法来使用。
>
>
> Best,
> Xinghalo
>
>
>
> --
>
> Benchao Li
> School of Electronics Engineering and Computer Science, Peking University
> Tel:+86-15650713730
> Email: libenchao@gmail.com; libenchao@pku.edu.cn
>


-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message