Flink Kubernetes Operator, 1.13 Release timeline

Hello everyone, I’m currently testing the 1.13 version of the Flink operator by building it from source and deploying it to my cluster. I need this version of the operator since it supports Flink 2.1. From what I can tell everything is working great in this snapshot version. I wanted to reach

DeclaringAsyncKeyedProcessFunction's and Flink 2 async state APIs

Hello everyone, I have a question about using the Async state APIs in a KeyedProcessFunction. I’m defining a pipeline like this, keyBy(KeySelector()).enableAsyncState().process(MyKeyedProcessFunction()). Inside MyKeyedProcessFunction I’m using the org.apache.flink.api.common.state.v2.ValueStat

Flink 2.0, large state and KeyedCoProcessFunction based stream joins - Async state store questions

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