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 Asahi Lee <97...@qq.com> on 2020/11/14 08:58:23 UTC
flink 1.11.2 如何配置时区
你好！ 我使用的是flink sql 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
我的程序的数据是json格式输出
Re: flink 1.11.2 如何配置时区
Posted by Jark Wu <im...@gmail.com>.
1. 现在 proctime() 在设计上确实有问题，目前返回类型是 timestamp, 而不是 timestamp with local time
zone， 所以不会考虑 session time zone，转成 string 会用 utc 时区。这个问题会在 FLINK-20162 [1]
中修复。
2. 可以看下这个文档[2].
Best,
Jark
[1]: https://issues.apache.org/jira/browse/FLINK-20162
[2]:
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/json.html#json-timestamp-format-standard
On Sat, 14 Nov 2020 at 17:21, Asahi Lee <97...@qq.com> wrote:
> 我使用的是format=json的格式，而flink使用的是jackson，那如何设置jackson的日期格式化的时区配置呢？
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人:
> "Asahi Lee"
> <
> 978466273@qq.com>;
> 发送时间: 2020年11月14日(星期六) 下午4:58
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: flink 1.11.2 如何配置时区
>
>
>
> 你好！ 我使用的是flink sql
> 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
> 我的程序的数据是json格式输出
回复：flink 1.11.2 如何配置时区
Posted by Asahi Lee <97...@qq.com>.
我使用的是format=json的格式，而flink使用的是jackson，那如何设置jackson的日期格式化的时区配置呢？
------------------ 原始邮件 ------------------
发件人: "Asahi Lee" <978466273@qq.com>;
发送时间: 2020年11月14日(星期六) 下午4:58
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: flink 1.11.2 如何配置时区
你好！ 我使用的是flink sql 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
我的程序的数据是json格式输出