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<xingh...@163.com> 写道: Hi, 我的时间字段就是proctime()产生的...因为当时有个time关键字的bug,所以按照这个confluence进行了修正。 后来使用时间字段的时候,就出了现在的问题。 https://issues.apache.org/jira/browse/FLINK-16068 Best, Xinghalo 在2020年04月15日 21:21,Benchao Li<libenc...@gmail.com> 写道: 这个原因是维表join的时候需要使用的时间是*有处理时间属性*[1] 的。 [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html 111 <xingh...@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: libenc...@gmail.com; libenc...@pku.edu.cn