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 , fat jar of the flink job application has those libraries but it cannot identify those extension functions at runtime and putting them to the lib folder is not a feasible choice. Can you give some pointer on this problem.. thanks in advance ..
I have tried multiple ways to load the classes using class.forname etc.. but nothing works even if the fat jar for the flink job application has the siddhi extensions in it.i don’t want to add those libraries to the jobmanage and taskmanagers lib folder everytime. Any help will be appreciated. Regards Dipanjan