Hi everyone,

I have a question regarding the async state store changes introduced with Flink 
2.x. Specifically, I'm wondering if it is currently possible or if any work is 
planned to allow enabling asynchronous state for a custom 
KeyedCoProcessFunction.

From what I understand, this is possible when using a custom 
KeyedProcessFunction by wrapping the custom function in an 
AsyncKeyedProcessOperator. However, I couldn't find any analogs for this 
operator that wrap a KeyedCoProcessFunction. I assume this is due to the 
complexities around a KeyedCoProcessFunction needing to map the state using 
different keys, but I wanted to check if I missed something.

Thanks a lot!

Reply via email to