Hi, I have 2 flink jobs, of which one produces records to kafka using kryo serializer and the other consumes records from kafka and deserializes with kryo. It has been working fine. Then I stopped both jobs with checkpoints and changed the consumer job to disable generic type and kryo to use avro serialization. However, when I resumed the 2 jobs from the checkpoint, both failed. It made sense the consumer job would fail, but why is the producer job also affected?
Thanks, Peng
