Hi Philip,
The JobManager should figure out the correct TaskManager for your query based
on the key. You mentioned that you get the result 1/3 of the time, is this 1/3
of the time for queries with exactly the same key or for queries with different
keys?
Also, could it be that the state
Dear Flink Users,
I’m getting started with Flink and I’ve bumped into a small problem. I have a
keyed stream like this:
val stream = env.addSource(consumer)
.flatMap(new ValidationMap()).name("ValidationMap")
.keyBy(x => (x.getObj.foo(), x.getObj.bar(), x.getObj.baz()))
.flatMap(new
