[jira] [Commented] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954205#comment-16954205 ] vinoyang commented on FLINK-14428: -- I read the source code again, you are right. It's not a problem. >

[jira] [Commented] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953581#comment-16953581 ] vinoyang commented on FLINK-14428: -- [~aljoscha] It seems after 1.9+ we introduced {{MailboxProcessor}}

[jira] [Commented] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953549#comment-16953549 ] Aljoscha Krettek commented on FLINK-14428: -- {{onProcessingTime()}} is invoked under the

[jira] [Commented] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953481#comment-16953481 ] vinoyang commented on FLINK-14428: -- [~aljoscha] and [~trohrmann] WDYT? > Non-consistency key access in