Hi, Tejas
This exception is caused by the Rule adding fields that cannot be recovered
from the historical Checkpoint. You can try to start job without recover from
checkpoint/savepoint.
And I double-checked that Rule as you write is recognized as a Pojo type
Best,
Weihua
> 2022年5月13日 上午7:31，
take a look at my question in email: “How to define
TypeInformation for Flink recursive resolved POJO” 😊 ?
Thanks,
Fuyao
From: Tejas B
Date: Thursday, May 12, 2022 at 16:32
To: Weihua Hu
Cc: user
Subject: [External] : Re: How to get flink to use POJO serializer when enum is
present in
Hi Weihua,
This is the error I am getting :
Caused by: org.apache.flink.util.FlinkException: Could not restore operator
state backend for
CoBroadcastWithNonKeyedOperator_8c5504f305beefca0724b3e55af8ea26_(1/1) from
any of the 1 provided restore options. at
org.apache.flink.streaming.api.operators.Ba
Hi, Tejas
These code is works in my idea environment.
Could you provide more error info or log?
Best,
Weihua
> 2022年5月10日 下午1:22，Tejas B 写道：
>
> Hi,
> I am trying to get flink schema evolution to work for me using POJO
> serializer. But I found out that if an enum is present in the POJO then
Hi Arvid,
Thanks for replying. But I have all the getters and setters in the example.
As you can see, the val2 field is commented and hence its getter and setter
are commented out. When restoring from a savepoint, I uncomment these and
get errors.
If I remove reference to the enum RuleType from the
Is this your whole Rule class? If so, then the issue is not the type of the
field but that you haven't added a setter and getter for it.
On Tue, May 10, 2022 at 7:23 AM Tejas B wrote:
> Hi,
> I am trying to get flink schema evolution to work for me using POJO
> serializer. But I found out that i
