- env
- flink 1.7.1
- kafka 1.0.1
I use Flink application in Streaming process. Read topic from kafka and sink it to kafka new Topic.
When i change application with new version of code and deploy, it comes to application execution failure.
If i deploy the same group.id after changing the application code, could there be a conflict with previous state checkpoint information?