GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3008
[FLINK-4973] Let LatencyMarksEmitter use StreamTask's ProcessingTimeService
The LatencyMarksEmitter class uses now the StreamTask's
ProcessingTimeService to schedule
latency mark emission. For that the ProcessingTimeService was extended to
have the method
scheduleAtFixedRate to schedule repeated tasks. The latency mark emission
is such a repeated
task.
cc @rmetzger.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixLatencyMarksEmitter
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3008.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 #3008
----
commit c06b3457f2b98969f444da07569656ac07727166
Author: Till Rohrmann <[email protected]>
Date: 2016-12-14T13:53:11Z
[FLINK-4973] Let LatencyMarksEmitter use StreamTask's ProcessingTimeService
The LatencyMarksEmitter class uses now the StreamTask's
ProcessingTimeService to schedule
latency mark emission. For that the ProcessingTimeService was extended to
have the method
scheduleAtFixedRate to schedule repeated tasks. The latency mark emission
is such a repeated
task.
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
