In my KeyedProcessFunction

onTimer()

function, I try to do

OnTimerContext.getCurrentKey()

which is returning a string, but my

KeySelector.getKey()

implementation returns a

Tuple2<String, String>

. This is leading to the following error

Type mismatch: cannot convert from String to Tuple2<String,String>

- any idea on how to fix this?

Something doesn't add up. Could it be that you have the wrong type signature on the KeyedProcessFunction?

That was exactly it. Found it later. Thanks.