Hi, 你提到的这两个issue都是在1.10.1版本中才会修复，但是现在还没有release1.10.1版本。 你现在是用release-1.10 branch编译的么？ 此外，是否方便也贴一下完整的DDL以及query呢？
111 <[email protected]> 于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<[email protected]> 写道： > Hi, > 我的时间字段就是proctime()产生的...因为当时有个time关键字的bug，所以按照这个confluence进行了修正。 > 后来使用时间字段的时候，就出了现在的问题。 > https://issues.apache.org/jira/browse/FLINK-16068 > Best， > Xinghalo > > > 在2020年04月15日 21:21，Benchao Li<[email protected]> 写道： > 这个原因是维表join的时候需要使用的时间是*有处理时间属性*[1] 的。 > > [1] > > https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html > > 111 <[email protected]> 于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: [email protected]; [email protected] > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
