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 crea
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. F
Hi Dipanjan,
Please double check whether the libraries are really contained in the job
jar you are submitting because if the library is contained in this jar,
then it should be on the classpath and you should be able to load it.
Cheers,
Till
On Thu, May 20, 2021 at 3:43 PM Dipanjan Mazumder wro
Hi ,
i am trying to integrate siddhi with flink while trying to use siddhi
extension function on deploying the job in flink cluster it is not able to find
those libraries at run time , so i had to explicitly put those libraries to the
/opt/flink/lib folder for the jobmanager and taskmanager
