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

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



[hidden email]

[史 正超]

在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));

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

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



[hidden email]

谢谢 我试试



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

[hailongwang]

Hi zjfplayer，
可以使用 Now() 函数，详见：https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/systemFunctions.html#temporal-functions
Now() 函数是 not deterministic，意思是对于每条记录都会重新计算。


Best，
Hailong Wang
在 2020-10-30 10:17:27，"[hidden email]" <[hidden email]> 写道：
>RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间
>
>
>
>[hidden email]

主要是现在是1.8版本 没这个函数



[hidden email]
 
发件人： hailongwang
发送时间： 2020-11-03 00:24
收件人： user-zh
主题： Re:flink实时流中如何实时获取当前时间
Hi zjfplayer，
可以使用 Now() 函数，详见：https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/systemFunctions.html#temporal-functions
Now() 函数是 not deterministic，意思是对于每条记录都会重新计算。
 
 
Best，
Hailong Wang
在 2020-10-30 10:17:27，"[hidden email]" <[hidden email]> 写道：
>RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间
>
>
>
>[hidden email]