Yes. This is the same problem with CURRENT_TIMESTAMP which was asked before in mailing list and JIRA. Changing the return type to WITH LOCAL TIME ZONE is not a small work, we should make event-time and watermark support this type. But I think this is in a high priority and should be fixed in the next release.
Best, Jark On Wed, 6 May 2020 at 09:47, Jingsong Li <[email protected]> wrote: > Hi, > > 这可能是个Bug。 > > Blink中默认使用timestamp WITHOUT time zone，所以它是无时区的。 > 而proctime目前还是带时区的产生了时间，我理解可能是应该产生无时区的时间。 > > CC: @Jark Wu <[email protected]> @Zhenghua Gao <[email protected]> > > Best, > Jingsong Lee > > On Tue, May 5, 2020 at 5:43 PM 祝尚 <[email protected]> wrote: > >> 同问，等待大佬回答 >> >> > 2020年5月1日 下午5:26，hb <[email protected]> 写道： >> > >> > >> > >> > ``` 代码 >> > 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 >
