[FLINK-17499] LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0, 1.11.0
• Fix Version/s: 1.10.1
• Component/s: API / State Processor
• Labels: pull-request-available
• Assignee: Seth Wiesman
• Reporter: Adam Laczynski
• Created: 03/May/20 14:36
• Updated: 10/May/20 11:38
• Resolved: 04/May/20 14:57

Description

@Override
public void register*ProcessingTime*Timer(long time) {
  ensureInitialized();
  internalTimerService.registerEventTimeTimer(VoidNamespace.INSTANCE, time);
}

Same issue for both registerEventTimeTimer and registerProcessingTimeTimer.

https://github.com/apache/flink/blob/master/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/LazyTimerService.java#L62

Issue Links

• links to: GitHub Pull Request #11980