flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners
Date Wed, 03 Aug 2016 15:51:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406108#comment-15406108

ASF GitHub Bot commented on FLINK-4282:

GitHub user aditivin opened a pull request:


    [FLINK-4282] [streaming] Added an offset parameter for processing time window ass…

    Added offset parameter for the processing time window assigners:
    - ProcessingTimeSessionWindows
    - SlidingProcessingTimeWindows
    - TumblingProcessingTimeWindows
    The offset is an optional parameter that can be added while creating these classes, and
it can be supplied as a long value or a TimeZone.
    Test cases for the change are present in WindowAssignerOffsetTest. There are tests for
positive, negative and TimeZone offsets for each of the classes.
    All Travis CI jobs passed.
    I haven't done it for the event time window assigners yet - I can add that if this is
all right.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/aditivin/flink FLINK-4282

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2331
commit 6b57c17a7b207b9e862d14afcc7c890377113d77
Author: zentol <chesnay@apache.org>
Date:   2016-07-22T15:50:10Z

    [FLINK-4282] Added an offset parameter for processing time window assigners


> Add Offset Parameter to WindowAssigners
> ---------------------------------------
>                 Key: FLINK-4282
>                 URL: https://issues.apache.org/jira/browse/FLINK-4282
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Aljoscha Krettek
> Currently, windows are always aligned to EPOCH, which basically means days are aligned
with GMT. This is somewhat problematic for people living in different timezones.
> And offset parameter would allow to adapt the window assigner to the timezone.

This message was sent by Atlassian JIRA

View raw message