flink 1.11.2 如何配置时区

[Asahi Lee]

你好！       我使用的是flink sql 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
我的程序的数据是json格式输出

[Asahi Lee]

我使用的是format=json的格式，而flink使用的是jackson，那如何设置jackson的日期格式化的时区配置呢？




------------------ 原始邮件 ------------------
发件人:                                                                                                                        "Asahi Lee"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年11月14日(星期六) 下午4:58
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;flink 1.11.2 如何配置时区



你好！&nbsp; &nbsp; &nbsp; &nbsp;我使用的是flink sql 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
我的程序的数据是json格式输出

[Jark]

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 <[hidden email]> wrote:

> 我使用的是format=json的格式，而flink使用的是jackson，那如何设置jackson的日期格式化的时区配置呢？
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "Asahi Lee"
>                                                                       <
> [hidden email]&gt;;
> 发送时间:&nbsp;2020年11月14日(星期六) 下午4:58
> 收件人:&nbsp;"user-zh"<[hidden email]&gt;;
>
> 主题:&nbsp;flink 1.11.2 如何配置时区
>
>
>
> 你好！&nbsp; &nbsp; &nbsp; &nbsp;我使用的是flink sql
> 1.11.2版本，通过proctime()在源上添加处理时间，发现生成的时间为UTC时间，而我需要的是+08的时间；而我通过设计env.java.opts参数设计jvm的时区参数也没有解决，请问我如何配置才可以拿到+08的时间？
> 我的程序的数据是json格式输出