pulsar-flink
pulsar-flink copied to clipboard
[Task] Add test case for backup & restore the connector state
Test Case
Flink state is backed up from system 1. Pulsar is installed on a system 2. The topic is created on system 2. Flink state is restored in system2. The cursor position in the flink state does not correspond to the cursor position of the topic in the Pulsar in system 2. With failOnDataLoss set to false, the flink job should run when started from the restored state. We are yet to validate this case.