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

Reply via email to