Lix created FLINK-6743:
--------------------------
Summary: .window(TumblingEventTimeWindows.of(Time.days(1),
Time.hours(-8))) doesn't work
Key: FLINK-6743
URL: https://issues.apache.org/jira/browse/FLINK-6743
Project: Flink
Issue Type: Bug
Components: DataStream API
Environment: Flink 1.2.0 and above.
Reporter: Lix
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?
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
