Hi All,
Found the solution ,
Problem: I was actually using an intermediate library to integrate siddhi with
Flink (https://github.com/haoch/flink-siddhi) and i was creating a SiddhiCEP
instance and then calling "define()" on that instance , while i was registering
the extension on the created instance , but the define method was creating an
internal SiddhiCEP instance and using that for processing. So i found that out
by debugging the application. It is an implementation problem with the library
itself.
Solution: i used from() method on the created SiddhiCEP instance instead of
define() and it was using the CEP i created for doing the rest of processing
and the registered extension were accounted similarly and so they were
recognised at runtime.
RegardsDipanjan
On Friday, May 21, 2021, 01:51:09 PM GMT+5:30, Salva Alcántara
<[email protected]> wrote:
Hi Dipanjan,
I agree with Till. If the extensions are are included in the jar for your
job, it should work. I was having the same doubts some weeks a go and can
confirm that as long as the jar includes those extensions, it works.
One thing I needed to do is to register the different extensions. For
example:
```
siddhiManager.setExtension("map:create", classOf[CreateFunctionExtension])
```
Regards,
Salva
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
