flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl0u <...@git.apache.org>
Subject [GitHub] flink pull request #2124: [FLINK-3647] Change StreamSource to use Processing...
Date Fri, 17 Jun 2016 12:26:53 GMT
GitHub user kl0u opened a pull request:


    [FLINK-3647] Change StreamSource to use Processing-Time Clock Service

    This PR changes the AutomaticWatermarkContext to user a pluggable processing time clock.
    allows for better testability of the code.
    This PR also contains the solution to FLINK-3646.

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

    $ git pull https://github.com/kl0u/flink FLINK-3646

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 #2124
commit 88c01d2ffbb38ad83343c730e38c6a20ccdb8089
Author: kl0u <kkloudas@gmail.com>
Date:   2016-05-12T12:16:14Z

    [FLINK-3464] Use Processing-Time Clock in Window Assigners/Triggers
    Introduces a custom TimeServiceProvider to the StreamTask.
    This is responsible for defining and updating the current
    processingtime for a task and handling all related action,
    such as registering timers for actions to be executed in
    the future.

commit 97dba2bd165fc33b52350c81f09f38dbf8f60e72
Author: kl0u <kkloudas@gmail.com>
Date:   2016-06-09T19:23:38Z

    [FLINK-3647] Change StreamSource to use Processing-Time Clock Service


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message