flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: TumblingEventTimeWindows with negative offset / Wrong documentation
Date Wed, 29 Mar 2017 15:18:25 GMT
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
>


Mime
View raw message