Hi,
Thanks for the reply incomingRule is nothing but incomingPattern it's a
typo and yes i am using in my program, here is my scenario i have streaming
of json events which need to be validated against a set of rules i have
multiple streams from which i am consuming data let say if i have Source
Could you please share with us the actual code that you are running.
Possibly without any debug statements. As I said in my first reply, I
can not rely relate the stack trace with the code you sent us. Moreover
in the code you sent us I can not see a way it could throw an Exception
at the line you
Hi all,
Just as an addition to what Dawid asked, I would also like to ask:
1) which Flink version are you using? because the stack trace line
numbers do not match the current master.
2) as a clarification (although maybe not relevant here), there is no
guarantee on the order of the elements, so
Hi Rahul.
Could you verify that the provided code is the one that fails? Something
does not seem right for me in the stacktrace. The stacktrace shows that
you call processElement recursively, but I can not see that in the code:
I have some interesting scenario i am working on pattern matching in flink
evaluating the incoming data against a set of patterns using
keyedbroadcastprocessfunction, when i am running the program in IDE i am
getting null pointer exception in processElements method when trying to
access
