[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774612#comment-16774612 ]
Jamie Grier edited comment on FLINK-10887 at 2/22/19 12:11 AM: --------------------------------------------------------------- [~thw] I'll create a new PR with a solution for the aggregand and result that works similarly to the aggregateFunction. This was as designed but I think it's an oversight. Thanks. was (Author: jgrier): [~thw] I'll update the PR with a solution for the aggregand and result that works similarly to the aggregateFunction. This was a designed but I think it's an oversight. Thanks. > Add source watermark tracking to the JobMaster > ---------------------------------------------- > > Key: FLINK-10887 > URL: https://issues.apache.org/jira/browse/FLINK-10887 > Project: Flink > Issue Type: Sub-task > Components: JobManager > Reporter: Jamie Grier > Assignee: Jamie Grier > Priority: Major > Labels: pull-request-available > Fix For: 1.8.0 > > Original Estimate: 24h > Time Spent: 50m > Remaining Estimate: 23h 10m > > We need to add a new RPC to the JobMaster such that the current watermark for > every source sub-task can be reported and the current global minimum/maximum > watermark can be retrieved so that each source can adjust their partition > read rates in an attempt to keep sources roughly aligned in event time. > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)