[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609987#comment-16609987
]
Hequn Cheng commented on FLINK-10284:
-------------------------------------
[~wind_ljy] Thanks for reporting the issue.
The window start of both `offset -8` and `offset 16` would be same. Check the
code bellow,
{code:java}
public static long getWindowStartWithOffset(long timestamp, long
offset, long windowSize) {
return timestamp - (timestamp - offset + windowSize) %
windowSize;
}
{code}
> TumblingEventTimeWindows's offset should can be less than zero.
> ---------------------------------------------------------------
>
> Key: FLINK-10284
> URL: https://issues.apache.org/jira/browse/FLINK-10284
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.6.0
> Reporter: Jiayi Liao
> Assignee: Jiayi Liao
> Priority: Major
>
> My goal is to create a window from 0am to the next day's 0am within GMT+8
> timezone, so I choose to use TumblingEventTimeWindows.of(Time.of(1,
> TimeUnit.DAYS)), which uses UTC timezone to implement the range of "day". And
> it doesn't allow me to write an offset -8 in the TumblingEventTimeWindows,
> which can help me fix the offset of timezone.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
