Hello Adeel,
after finishing your scheduler code, you package it into a jar file for
installation. You can probably use Maven to do it for you as it
automates everything well. You use the relevant POM with Maven to
compile your scheduler.
Then you have to place your jar file at
Perhaps you can try some things depending on how feasible they it is for your
case:
1- Try to design and deploy your topology to maximize communication within a
worker process instead fo across worker processes. 2- Alternatively you can
spin up multiple single worker instances of you toplo3-