You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/30 06:50:00 UTC

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

谢谢 我试试



zjfplayer@hotmail.com
 
发件人: 史 正超
发送时间: 2020-10-30 14:48
收件人: user-zh@flink.apache.org
主题: 回复: flink实时流中如何实时获取当前时间
在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));
 
``
________________________________
发件人: zjfplayer@hotmail.com <zj...@hotmail.com>
发送时间: 2020年10月30日 3:17
收件人: user-zh <us...@flink.apache.org>
主题: flink实时流中如何实时获取当前时间
 
RT,sql方式中怎么实时取当前消息处理的时间,来插入数据库当作当前更新时间?现在用current_timestamp发现不会变,只是第一次的时间
 
 
 
zjfplayer@hotmail.com