[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Seth Wiesman reassigned FLINK-17499: ------------------------------------ Assignee: Seth Wiesman > LazyTimerService used to register timers via State Processing API incorectly > mixes event time timers with processing time timers > -------------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-17499 > URL: https://issues.apache.org/jira/browse/FLINK-17499 > Project: Flink > Issue Type: Bug > Components: API / State Processor > Affects Versions: 1.10.0 > Reporter: Adam Laczynski > Assignee: Seth Wiesman > Priority: Major > > @Override > public void register*{color:#FF0000}ProcessingTime{color}*Timer(long time) { > ensureInitialized(); > > internalTimerService.register{color:#ff0000}*EventTime*{color}Timer(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] -- This message was sent by Atlassian Jira (v8.3.4#803005)