hequn8128 commented 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 the function that **clearly** indicates that the time of 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
