Hi,
Here's our use case :
We are planning to build a rule based engine on top of flink with huge number
of rules(1000s). the rules could be stateless or stateful.
Example stateless rule is : A.id = 3 && A.name = 'abc' || A.color = red.
Example stateful rule is : A is event.id =3, B is event.name
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 the
POJO serializer is not used. Example of my POJO is as follows :
public class Rule {
String id;int val;
RuleType ruleType;//Newly added field//int val2
t 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 if an enum is pr
t's falling back to Kryo serializer instead
of POJO serializer.
Thanks,
Tejas
On Thu, May 12, 2022 at 7:33 AM Weihua Hu wrote:
> Hi, Tejas
>
> These code is works in my idea environment.
> Could you provide more error info or log?
>
>
> Best,
> Weihua
>
> 2022年5月
