Hi, 一种简单的方式,自己手动在proctime上加8个小时,目前这个时区设置好像是不起作用的。
> -----原始邮件----- > 发件人: hb <343122...@163.com> > 发送时间: 2020-05-12 13:02:44 (星期二) > 收件人: user-zh@flink.apache.org > 抄送: > 主题: Re:flink sql 处理时间 时区问题 > > 有人能帮忙看下这个问题么 > > > > 在 2020-05-01 16:26:35,"hb" <343122...@163.com> 写道: > > > > ``` 代码 > val env = StreamExecutionEnvironment.getExecutionEnvironment > val settings: EnvironmentSettings = > EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build() > val tEnv: StreamTableEnvironment = StreamTableEnvironment.create(env, > settings) > > > val t2 = env.fromElements("a", "b", "c") > t2.toTable(tEnv, 'f1, 'proc.proctime).toAppendStream[Row].print() > ``` > > > // 时区上海, 当前时间为 2020-05-01 15点 > // 结果显示 a,2020-05-01T09:11:05.633, 处理时间相差8小时, 请问如何让 proctime 结果显示不差8小时. > > > > > ------------------------------ 刘大龙 浙江大学 控制系 智能系统与控制研究所 工控新楼217 地址:浙江省杭州市浙大路38号浙江大学玉泉校区 Tel:18867547281