Re: Timestamp conversion problem in Flink Table/SQL

2018-12-28 Thread Hequn Cheng
Hi Jiayichao, The two methods do not have to appear in pairs, so you can't use timestamp.getTime() directly. Currently, Flink doesn't support time zone configuration. The timestamp(time of type Timestamp) always means the time in UTC+0. So in the test of your pr[1], the output timestamp means a ti

Timestamp conversion problem in Flink Table/SQL

2018-12-27 Thread jia yichao
Hi community, Recently I have encountered a problem with time conversion in Flink Table/SQL . When the processed field contains a timestamp type, the code of the flink table codegen first converts the timestamp type to a long type, and then converts the long type to a timestamp type on output.