hequn8128 edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-450556445 @lamber-ken Yes, you are right. It would be good if we can solve it in a simple way. However, you pr would bring some side effects. Basically, Flink returns timestamp in UTC+0. With your pr, the output time is a local timestamp for proctime. However, you only changed one place about how to represent a timestamp. There are a lot of other places still return timestamp in UTC+0 which would **bring confusion and inconsistency**. Flink also returns and only returns local timestamp in functions that **clearly** indicate that the time of the return type is a local timestamp, such as the `CURRENT_TIMESTAMP` function. `String sqlQuery = "select proctime, LOCALTIMESTAMP from MyTable";` This is why offset is added in the place of the link you have provided. Best, Hequn
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
