August 2017
Beginner to intermediate
284 pages
6h 51m
English
We need to create a JAR for the CustomScheduler class, and place it in $STORM_HOME/lib/, and tell Nimbus to use the new scheduler by appending the following lines to the configuration file at $STORM_HOME/conf/storm.yaml:
storm.scheduler: "com.stormadvance.storm_kafka_topology.CustomScheduler"
Restart the Nimbus daemon to reflect the changes to the configuration.
Now, if we deploy the same topology shown in the previous diagram, then the distribution of executors will look like this (Bolt2 is assigned to a GPU-typed supervisor):

Read now
Unlock full access