You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/06/13 06:41:01 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler closed FLINK-6906.
-----------------------------------
    Resolution: Duplicate

> TumblingProcessingTimeWindows  can't  set offset parameter to a negative value
> ------------------------------------------------------------------------------
>
>                 Key: FLINK-6906
>                 URL: https://issues.apache.org/jira/browse/FLINK-6906
>             Project: Flink
>          Issue Type: Bug
>          Components: DataStream API
>    Affects Versions: 1.2.0, 1.3.0, 1.2.1, 1.2.2
>            Reporter: yanam
>              Labels: easyfix
>   Original Estimate: 1h
>  Remaining Estimate: 1h
>
> Excuse my English.
> In the DataStream API,I specify 
> {code:java}
> org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows 
> {code}
>  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.
> {code:java}
> org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
> {code},
> {code:java}
> org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
> {code},
> {code:java}
> org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
> {code} has the same problem.
> We should use the offset absolute value to compare with the size in the construct method.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)