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 03:17:27 UTC

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

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



zjfplayer@hotmail.com

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

Posted by "zjfplayer@hotmail.com" <zj...@hotmail.com>.

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



zjfplayer@hotmail.com
 
发件人： 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，"zjfplayer@hotmail.com" <zj...@hotmail.com> 写道：
>RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间
>
>
>
>zjfplayer@hotmail.com

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

Posted by hailongwang <18...@163.com>.

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，"zjfplayer@hotmail.com" <zj...@hotmail.com> 写道：
>RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间
>
>
>
>zjfplayer@hotmail.com

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

Posted by "zjfplayer@hotmail.com" <zj...@hotmail.com>.

谢谢 我试试



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

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

Posted by 史正超 <sh...@outlook.com>.

在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