[FLINK-21803] Tumbling / Sliding windows are unaware of daylight savings time

• Type: Improvement
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.12.2
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Craig Smoothey
• Created: 15/Mar/21 16:43
• Updated: 25/Nov/21 10:43

Description

It is currently possible to specify an "offset" for tumbling / sliding windows. The offset is however immutable. This creates a problem for aggregations that have to be performed in a timezone which utilises daylight savings time for half of the year. For example. If one is aggregating data by day in the New York time zone, then for half of the year, the offset is 5 hours (relative UTC) and for the other half of the year, the offset is 4 hours (relative UTC). There is no way to construct tumbling / sliding windows to specify daylight savings time behaviour. It would be helpful if there was a constructor for tumbling / sliding windows to specify the timezone that the aggregation must be performed in (default = UTC). The tumbling / sliding window would then be required to automatically change the offset depending on whether daylight savings time is active or not for the specified time zone. My application is using the DataStream API.

Issue Links

• is related to: FLINK-21617 FLIP-162: Consistent Flink SQL time function behavior
• relates to: FLINK-20387 Support defining event time attribute on TIMESTAMP_LTZ column