Hi,
这可能是个Bug。
Blink中默认使用timestamp WITHOUT time zone，所以它是无时区的。
而proctime目前还是带时区的产生了时间，我理解可能是应该产生无时区的时间。
CC: @Jark Wu <imj...@gmail.com> @Zhenghua Gao <doc...@gmail.com>
Best,
Jingsong Lee
On Tue, May 5, 2020 at 5:43 PM 祝尚 <17626017...@163.com> wrote:
> 同问，等待大佬回答
>
> > 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小时.
>
>
--
Best, Jingsong Lee
