[FLINK-6906] TumblingProcessingTimeWindows can't set offset parameter to a negative value

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.2.0, 1.2.1, 1.2.2, 1.3.0
• Component/s: API / DataStream
• Labels: easyfix
• Flags: Important
• Assignee: Unassigned
• Reporter: yanam
• Created: 13/Jun/17 04:11
• Updated: 13/Jun/17 06:40
• Resolved: 13/Jun/17 06:40

Description

Excuse my English.

In the DataStream API,I specify

org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows 

an offset of a negative value such as Time.hours(-8),When trying to submit the Job will throw IllegalArgumentException "TumblingProcessingTimeWindows parameters must satisfy 0 <= offset < size" .

This is problematic for living in somewhere which is not using UTC-00:00 time.

org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows

,

org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows

,

org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows

has the same problem.

We should use the offset absolute value to compare with the size in the construct method.

Issue Links

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