Re: How to get flink to use POJO serializer when enum is present in POJO class

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月

Re: How to get flink to use POJO serializer when enum is present in POJO class

the Rule class, then everything works fine. So it's definitely a enum issue. What I am looking for is, why doesn't flink recognize enum for POJO serializer ? Thanks, Tejas On Tue, May 10, 2022 at 2:06 AM Arvid Heise wrote: > Is this your whole Rule class? If so, then the issue is no

How to get flink to use POJO serializer when enum is present in POJO class

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

Looking for suggestions about multithreaded CEP to be used with flink

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

Re: Running multiple CEP pattern rules

Hi Dawid, Do you have any plans to bring this functionality in flink CEP in future ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Running multiple CEP pattern rules

Hi, We are running into errors when running multiple CEP patterns. Here’s our use-case : We are planning to build a rule based engine on top of flink with huge number of rules and doing a POC for that. For POC we have around 1000 pattern based rules which we are translating into CEP patterns and ru

Incorrect flink documentation example

Hi, I was trying out examples given here to convert Datastream to Table and one of the example gives out error. My code is as follows : /StreamExecutionEnvironment env = S

SQL match recognize output all columns

Hi, Is there a way to output all columns from match_recognize MEASURES clause ? I have tried following approaches : 1. /SELECT * FROM events MATCH_RECOGNIZE (PARTITION BY org_id ORDER BY proctime MEASURES A.* AS startId ONE ROW PER MATCH PATTERN (A C* B) DEFINE A AS A.tag = 'tag1', C AS C.tag <> 't

Nested match_recognize query not supported in SQL ?

Hi, I am using flink 1.11 and trying nested query where match_recognize is inside, as shown below : /select * from events where id = (SELECT * FROM events MATCH_RECOGNIZE (PARTITION BY org_id ORDER BY proctime MEASURES A.id AS startId ONE ROW PER MATCH PATTERN (A C* B) DEFINE A AS A.tag = 'tag1', C