HI, Peng. Do these two jobs have any dependency? Or Could you please share the specific logic of the two jobs if convenient ? Could you also share the failure message of the producer job ? In my opinion, if the two tasks have no other association, as you said, the consumer job will fail due to unsupported scheme evolution, but it should not affect the producer job.
On Tue, Jun 6, 2023 at 2:58 PM Peng Peng <pengpeng8...@gmail.com> wrote: > 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 > -- Best, Hangxiang.
