I'm currently using a ProcessFunction after a keyBy() and can't find a way to get the key. I'm currently storing it in a ValueState<String> within processElement and set it all the time, so that I can access it in onTimer(). Is there a better way to get the key? We are using Flink 1.3 at the moment.


Reply via email to