[
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 <kklou...@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 <kklou...@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)
