谢谢 我试试


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

回复