Hi Francis, Actually it is implemented[1,2] but has not been released yet. This allows you to write a customized `KeyedCoProcessFunction` using async state. This will be released in the next version (2.1). It would be great if you could try this out on the master branch of Flink to see if there is any problem, we appreciate any testing and feedback before the new release.
[1] https://issues.apache.org/jira/browse/FLINK-37521 [2] https://github.com/apache/flink/pull/26328 Best, Zakelly On Mon, Apr 28, 2025 at 5:52 PM Francis Altomare < francisaltom...@helpscout.com> wrote: > 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!
