Hi Mäki,
some additions to Greg's answer: The flatMapWithState shortcut of the Scala
API uses Flink's key-value state while your TestCounters class uses the
Checkpointed interface.
As Greg said, the checkpointed interface operates on an operator level not
per key. The key-value state automatically
Hi Mäki,
This is the expected output. Your RichFlatMapFunction is opened once per
task and you are sharing counterValue for all keys processed by that task.
Greg
On Mon, Dec 19, 2016 at 11:38 AM, Mäki Hanna wrote:
> Hi,
>
>
>
> I'm trying to calculate stateful counts per key with checkpoints
