Thanks I would have open the issue but wanted to make sure this is a code bug and not a documentation bug.
2017-03-29 17:18 GMT+02:00 Timo Walther <twal...@apache.org>: > Hi Vladislav, > > thank you very much for reporting this. You are right this is bug. I > opened an issue for it: https://issues.apache.org/jira/browse/FLINK-6214 > > I think it will be solved soon. > > Regards, > Timo > > > Am 29/03/17 um 16:57 schrieb Vladislav Pernin: > > Hi, >> >> The documentation mentions the possibility to use a negative offset with >> a TumblingEventTimeWindows : >> >> // 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>); >> >> >> But the code will throw an IllegalArgumentException : >> >> if (offset < 0 || offset >= size) { >> throw new IllegalArgumentException("TumblingEventTimeWindows >> parameters must satisfy 0 <= offset < size"); >> } >> >> >> Regards, >> Vladislav >> >> >
