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 沉醉寒風 <10...@qq.com> on 2021/02/01 02:50:19 UTC
回复： flink sql时区问题
在代码中这样设置 streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8")) 也不管用. 还是要自己手动去加减时间才能做到,方法比较笨,
------------------ 原始邮件 ------------------
发件人: "user-zh" <xbjtdcq@gmail.com>;
发送时间: 2021年2月1日(星期一) 上午10:46
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: flink sql时区问题
Hi,
时区不生效在你的代码中是体现在那些地方呀？目前flink sql是有些时区问题，社区也希望在1.13能解决掉。
> 在 2021年2月1日，10:42，沉醉寒風 <1039601304@qq.com> 写道：
>
> streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))
Re: flink sql时区问题
Posted by Leonard Xu <xb...@gmail.com>.
嗯，flink 中 很多时间函数比如PROCTIME()/CURRENT_TIMESTAMP 返回的值都是 UTC+0的时间值，这里的timezone设置对这些函数不生效的，这些函数是有点时区问题的，
目前只能在代码里通过加减时区偏移绕过。
> 在 2021年2月1日，10:50，沉醉寒風 <10...@qq.com> 写道：
>
> 在代码中这样设置 streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8")) 也不管用. 还是要自己手动去加减时间才能做到,方法比较笨,
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "user-zh" <xbjtdcq@gmail.com>;
> 发送时间: 2021年2月1日(星期一) 上午10:46
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: Re: flink sql时区问题
>
>
>
> Hi,
> 时区不生效在你的代码中是体现在那些地方呀？目前flink sql是有些时区问题，社区也希望在1.13能解决掉。
>
>
> > 在 2021年2月1日，10:42，沉醉寒風 <1039601304@qq.com> 写道：
> >
> > streamTableEnv.getConfig().setLocalTimeZone(ZoneId.of("+8"))