Hi，
是的，我都有修改.
那我去jira里面重新开个issue？
另外，1.10.1或者1.11大概什么时间发布呢？我已经合并了很多PR，现在的版本有点乱了。
Best,
Xinghalo
Hi,
基于1.10 源码按照jira里面的PR修改不行么？
跟hbase的ddl关系应该不大，就发一个kafka的吧。
//代码占位符
Flink SQL> CREATE TABLE kafka_test1 (
//代码占位符
Flink SQL> CREATE TABLE kafka_test1 (
> id varchar,
> a varchar,
> b int,
> ts as PROCTIME()
> ) WITH (
> 'connector.type' = 'kafka',
> 'connector.version' = '0.11
Hi,
我的时间字段就是proctime()产生的...因为当时有个time关键字的bug，所以按照这个confluence进行了修正。
后来使用时间字段的时候，就出了现在的问题。
https://issues.apache.org/jira/browse/FLINK-16068
Best，
Xinghalo
在2020年04月15日 21:21，Benchao Li 写道：
这个原因是维表join的时候需要使用的时间是*有处理时间属性*[1] 的。
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table
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 写道：
Hi,
我的时间字段就是proctime()产生的..
Hi,
现在直接使用DDL声明可以正常使用吗？我这边使用的时候发现，FOR SYSTEM_TIME AS OF o.proctime
会报类型不匹配问题…timestamp(3)和time attribute 不匹配.
所以现在只能使用connector内部提供的Lookup function手动注册成 table function，使用lateral table
xxx的语法来使用。
Best,
Xinghalo
