[
https://issues.apache.org/jira/browse/FLINK-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lix updated FLINK-6743:
-----------------------
Affects Version/s: 1.2.0
Environment: Flink 1.2.0. (was: Flink 1.2.0 and above.)
> .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
> Affects Versions: 1.2.0
> Environment: Flink 1.2.0.
> 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)
