[FLINK-11223] Time zone problem for time processing function

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.2, 1.8.0
• Component/s: Table SQL / API
• Labels: auto-unassigned
• Assignee: Unassigned
• Reporter: sunjincheng
• Created: 27/Dec/18 03:46
• Updated: 29/Apr/21 13:51
• Resolved: 29/Apr/21 13:51

Description

SQL:

Data.+=(("001", "flink", new Timestamp(1545803501000L)))
tab...toTable(tEnv, 'a, 'b, 'rowtime2, 'rowtime.rowtime)
val sqlQuery = "SELECT rowtime2, rowtime FROM tab"

Result:

2018-12-26 13:51:41.0, 2018-12-26 05:51:41.0

My local time zone is UTC/GMT+08.

Issue Links

• is related to: FLINK-21617 FLIP-162: Consistent Flink SQL time function behavior
• relates to: FLINK-20162 Fix time zone problems for some time related functions