Hi Team,

I am running flink 1.11 kinesis consumer with say N kinesis shards, but i want 
to increase/decrease shards to N+M or N-M.
Once i do that my flink consumer need to be restarted with changed parallelism. 
But i am unable to restart from existing checkpoint because of change in number 
of shards.

How do i solve this problem of restarting from existing checkpoint which was 
created with respect to N shards but now while restating we have more or less 
shards?

Thanks,
 Vijay

Reply via email to