[FLINK-6743] .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) doesn't work

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.2.0
• Component/s: API / DataStream

Environment

Flink 1.2.0.

• Flags: Important
• Assignee: Unassigned
• Reporter: Lix
• Created: 28/May/17 10:39
• Updated: 28/May/17 13:27
• Resolved: 28/May/17 13:27

Description

The tutorial on the official website says that we can use

// daily tumbling event-time windows offset by -8 hours.
input
.keyBy(<key selector>)
.window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8)))
.<windowed transformation>(<window function>);

when our timezone is UTC+8, which is in China. But when I tried to run this code, it just reported an error:

Exception in thread "main" java.lang.IllegalArgumentException: TumblingProcessingTimeWindows parameters must satisfy 0 <= offset < size
at org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.<init>(TumblingProcessingTimeWindows.java:54)
at org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.of(TumblingProcessingTimeWindows.java:111)

How then, should I write my code to make a tumbling window which clears every day at 00:00, when my timezone is UTC+8?

Issue Links

• duplicates: FLINK-6214 WindowAssigners do not allow negative offsets