你好,这个是预期中的。在新的类型系统下,我们将使用 LocalDateTime 作为 TIMESTAMP 类型的默认对象。 同时我们还禁用了 long 和 TIMESTAMP 对象的直接互转。 具体的原因和细节可以看: https://cwiki.apache.org/confluence/display/FLINK/FLIP-37%3A+Rework+of+the+Table+API+Type+System
Best, Kurt On Fri, Apr 3, 2020 at 4:58 PM 1193216154 <[email protected]> wrote: > > 你好,最近改成blinkplanner发现了两个问题。及时两者生成的proctime的时间类型不同,一个是TimeStamp,一个是LocalDateTime。 > > > org.apache.flink.table.dataformat.DataFormatConverters中TimestampConverter 的 > > toInternalImpl方法只支持TimeStamp的参数,而我遇见的情况是传进了long类型,导致类转换异常,如果能重载toInternalImpl方法加一个long,或许可以解决我的问题 > ------------------ 原始邮件 ------------------ > 发件人: "Kurt Young"<[email protected]>; > 发送时间: 2020年4月1日(星期三) 上午9:22 > 收件人: "user-zh"<[email protected]>; > > 主题: 【反馈收集】在 1.11 版本中将 blink planner 作为默认的 planner > > > > 大家好, > > 正如大家所知,Blink planner 是 Flink 1.9 版本中引入的一个全新的 Table API 和 SQL 的翻译优化 > 器,并且我们已经在 1.10 版本中将其作为 SQL CLI 的默认 planner。由于社区很早就已经决定不再 > 针对老的优化器去增添任何新的功能,所以从功能和性能上来说,老的 flink planner 已经缺了很多 > 现在社区最新的 SQL 相关的功能,比如新的类型系统,更多的DDL的支持,以及即将在 1.11 发布 > 的新的 TableSource 和 TableSink 接口和随之而来的对 Binlog 类日志的解析。 > > 因此我们打算尝试在接下来这个 1.11 版本发布时将 blink planner 升级为默认的 planner。但在此之 > 前,我们希望听听您的反馈。尤其是一些使用过程的体验,和您观察到的或者经历过的 blink planner > 做不了的事情从而导致您退回了老的 flink planner 的原因,可能是两边功能不对等,或者 blink planner > 有什么新的 bug 而老的 planner 没有。我们距离 1.11 的需求冻结还有差不多一个月的时间,收到 > 您的反馈之后,我们有足够的时间进行修复和完善。 > > 希望听到您宝贵的声音和意见,谢谢。 > > Best, > Kurt
