同问,等待大佬回答
> 2020年5月1日 下午5:26,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小时.