谢谢你!第二个问题确实是我版本太低问题,我flink版本是1.12.1。 第一个问题,是因为我通过flink写入iceberg 表中,然后通过presto查询iceberg表,其他字段的表都可以查询,但是当写入的是含有TIMESTAMP 类型的表时,presto查询如下报错:
Query failed (#20210816_020321_00011_wa8bs) in your-presto: Cannot convert from Iceberg type 'timestamp' (TIMESTAMP) to Presto type 所以,我怀疑要么flink TIMESTAMP 类型中间带T问题,要么presto(0.258版本)问题。如果这个问题您也知道答复下,感激不尽。 在 2021-08-16 12:26:27,"Leonard Xu" <xbjt...@gmail.com> 写道: >Hi, >你贴的图都挂了,需要传图可以用下图床工具,代码少可以直接贴代码。 >TIMESTAMP 类型中 显示的T 没有任何含义,只是 format 一个时间戳时的一个分割符,你最终把 TIMESTAMP >写入到你的sink,你自己的sink(比如mysql)会有其自己的format。 >第二个问题,看不到你的图,你看下你flink的版本,1.13后这个TIMESTAMP_LTZ类型支持才完善的。 > >祝好, >Leonard > > >> 在 2021年8月16日,10:27,Geoff nie <geoff_...@163.com> 写道: >> >> 问题一:flink timestamp时间戳为何中间多了个T,怎么才能少去中间T呢? >> >