flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Lix (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6743) .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) doesn't work
Date Sun, 28 May 2017 10:40:04 GMT
Lix created FLINK-6743:

             Summary: .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) doesn't
                 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.
    .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

View raw message