Re: flink sql时区问题

Sun, 31 Jan 2021 18:57:50 -0800 

嗯，flink 中 很多时间函数比如PROCTIME()/CURRENT_TIMESTAMP 返回的值都是 
UTC+0的时间值，这里的timezone设置对这些函数不生效的，这些函数是有点时区问题的，
目前只能在代码里通过加减时区偏移绕过。

> 在 2021年2月1日，10:50，沉醉寒風 <1039601...@qq.com> 写道：
> 
> 在代码中这样设置 streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8")) 
> 也不管用.&nbsp; &nbsp;还是要自己手动去加减时间才能做到,方法比较笨,&nbsp;
> 
> 
> 
> 
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:                                                                          
>                                               "user-zh"                       
>                                                              
> <xbjt...@gmail.com&gt;;
> 发送时间:&nbsp;2021年2月1日(星期一) 上午10:46
> 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
> 
> 主题:&nbsp;Re: flink sql时区问题
> 
> 
> 
> Hi,
> 时区不生效在你的代码中是体现在那些地方呀？目前flink sql是有些时区问题，社区也希望在1.13能解决掉。
> 
> 
> &gt; 在 2021年2月1日，10:42，沉醉寒風 <1039601...@qq.com&gt; 写道：
> &gt; 
> &gt; streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))

回复