flink sql时区问题

[沉醉寒風]

streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))

[Leonard Xu]

Hi,
时区不生效在你的代码中是体现在那些地方呀？目前flink sql是有些时区问题，社区也希望在1.13能解决掉。


> 在 2021年2月1日，10:42，沉醉寒風 <[hidden email]> 写道：
>
> streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))

[沉醉寒風]

在代码中这样设置 streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8")) 也不管用.&nbsp; &nbsp;还是要自己手动去加减时间才能做到,方法比较笨,&nbsp;




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2021年2月1日(星期一) 上午10:46
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: flink sql时区问题



Hi,
时区不生效在你的代码中是体现在那些地方呀？目前flink sql是有些时区问题，社区也希望在1.13能解决掉。


&gt; 在 2021年2月1日，10:42，沉醉寒風 <[hidden email]&gt; 写道：
&gt;
&gt; streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))

[Leonard Xu]

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

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