repeated data sink to redis

It seems that the redis sink is not very suitable for some specific circumstances.
For example, I want to do a word count and I enable the checkpoint machenism, it seems to be wrong if I start my program from checkpoint when my program fails, because some data that already sent will be sent to redis sink again.