Re: flink-1.10-sql 维表问题

1.10.1最近正在准备发布，还有几个blocker的issue，应该快了。 1.11的话，应该还比较久，现在都还没有feature freeze。 如果你可以在master上复现这个问题的话，可以建一个issue。 111 于2020年4月16日周四 上午11:32写道： > Hi， > 是的，我都有修改. > 那我去jira里面重新开个issue？ > > > 另外，1.10.1或者1.11大概什么时间发布呢？我已经合并了很多PR，现在的版本有点乱了。 > Best, > Xinghalo -- Benchao Li School of Electronics

回复： flink-1.10-sql 维表问题

Hi， 是的，我都有修改. 那我去jira里面重新开个issue？ 另外，1.10.1或者1.11大概什么时间发布呢？我已经合并了很多PR，现在的版本有点乱了。 Best, Xinghalo

Re: flink-1.10-sql 维表问题

https://issues.apache.org/jira/browse/FLINK-16068 https://issues.apache.org/jira/browse/FLINK-16345 上面这两个issue的修改都加到了1.10上了么？如果是的话，那这可能是还有其他的bug。 如果你可以在1.10和或者master分支的最新代码上复现这个问题的话，可以建一个issue来跟踪下这个问题。 111 于2020年4月16日周四 上午10:46写道： > Hi, > 基于1.10 源码按照jira里面的PR修改不行么？ >

回复： flink-1.10-sql 维表问题

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' =

Re: flink-1.10-sql 维表问题

Hi, 你提到的这两个issue都是在1.10.1版本中才会修复，但是现在还没有release1.10.1版本。 你现在是用release-1.10 branch编译的么？ 此外，是否方便也贴一下完整的DDL以及query呢？ 111 于2020年4月16日周四 上午8:22写道： > Hi, > 更正一下，我的问题跟这个类似，遇到的问题也在评论中： > >

回复： flink-1.10-sql 维表问题

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]

回复： flink-1.10-sql 维表问题

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,

Re: flink-1.10-sql 维表问题

这个原因是维表join的时候需要使用的时间是*有处理时间属性*[1] 的。 [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/time_attributes.html 111 于2020年4月15日周三 下午9:08写道： > Hi, > 现在直接使用DDL声明可以正常使用吗？我这边使用的时候发现，FOR SYSTEM_TIME AS OF o.proctime > 会报类型不匹配问题…timestamp(3)和time attribute 不匹配. > > >

回复： flink-1.10-sql 维表问题

Hi, 现在直接使用DDL声明可以正常使用吗？我这边使用的时候发现，FOR SYSTEM_TIME AS OF o.proctime 会报类型不匹配问题…timestamp(3)和time attribute 不匹配. 所以现在只能使用connector内部提供的Lookup function手动注册成 table function，使用lateral table xxx的语法来使用。 Best, Xinghalo

Re: flink-1.10-sql 维表问题

JDBC connector 支持作为维表，DDL无需特殊字段指定。部分可选的参数可以控制temporary join行为[1]。 用作维表join时，需要使用特殊的join语法 [2] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#jdbc-connector [2] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sql/queries.html#joins

Re: flink-1.10-sql 维表问题

Hi， 维表创建的DDL跟普通的source没有区别，主要是在使用的时候，需要使用维表join专有的语法。 SELECT o.amout, o.currency, r.rate, o.amount * r.rateFROM Orders AS o JOIN LatestRates FOR SYSTEM_TIME AS OF o.proctime AS r ON r.currency = o.currency guaishushu1...@163.com 于2020年4月15日周三 下午7:48写道： > hi 大家 >

flink-1.10-sql 维表问题

hi 大家 想问下flink-1.10-sql支持维表DDL吗，看社区文档好像mysql和hbase支持，但是需要什么字段显示声明为创建的表是维表呀？ guaishushu1...@163.com