[FLINK-17816] Change Latency Marker to work with "scheduleAtFixedDelay" instead of "scheduleAtFixedRate"

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Jiayi Liao
• Reporter: Stephan Ewen
• Created: 19/May/20 18:18
• Updated: 05/Jun/20 08:47
• Resolved: 05/Jun/20 08:47

Description

Latency Markers and other periodic timers are scheduled with scheduleAtFixedRate. That means every X time the callable is called. If it blocks (backpressure) is can be called immediately again.

I would suggest to switch this to scheduleAtFixedDelay to avoid calling for a lot of latency marker injections when there is no way to actually execute the injection call.

Issue Links

• links to: GitHub Pull Request #12416