Hi,
I have a flink job that can run on 1.20.0 but not 1.19.0. The error message
is as below:
Caused by: java.lang.ClassNotFoundException: org.apache.flink.core.
execution.RestoreMode.
So I compared the flink-core jar of both versions and it looks like the
1.19.0 one does not have this RestoreMod
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 wrote:
>
>> Hi,
>>
>> I have 2 flink jobs, of which one produces records to
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
