回复: flink实时流中如何实时获取当前时间

Thu, 29 Oct 2020 23:49:31 -0700 

在source表上加上 proctime AS PROCTIME()的字段 ， 
下游取的时候就用proctime转，注意时差的问题。比如用FROM_UNIXTIME(CAST(proctime AS BIGINT), 
'yyyy-MM-dd HH:mm:ss') 函数时，在table config里设置时区
``` java

streamTableEnv.getConfig().setLocalTimeZone(ZoneOffset.ofHours(8));

``
________________________________
发件人: [email protected] <[email protected]>
发送时间: 2020年10月30日 3:17
收件人: user-zh <[email protected]>
主题: flink实时流中如何实时获取当前时间

RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间



[email protected]

回复