You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 12:27:05 UTC

[jira] [Commented] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service

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

ASF GitHub Bot commented on FLINK-3647:
---------------------------------------

GitHub user kl0u opened a pull request:

    https://github.com/apache/flink/pull/2124

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

    This PR changes the AutomaticWatermarkContext to user a pluggable processing time clock. This
    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:

    https://github.com/apache/flink/pull/2124.patch

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 <kk...@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 <kk...@gmail.com>
Date:   2016-06-09T19:23:38Z

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

----


> Change StreamSource to use Processing-Time Clock Service
> --------------------------------------------------------
>
>                 Key: FLINK-3647
>                 URL: https://issues.apache.org/jira/browse/FLINK-3647
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Kostas Kloudas
>
> Currently, the {{StreamSource.AutomaticWatermarkContext}} has it's own timer service. This should be changed to use the Clock service introduced in FLINK-3646 to make watermark emission testable by providing a custom Clock.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)