public final class JobMasterExample
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args)
this main method is for locally testing only
A JobMaster instance is started locally on the default port:
edu.iu.dsc.tws.master.JobMasterContext.JOB_MASTER_PORT_DEFAULT = 11011
|
public static void main(java.lang.String[] args)
numberOfWorkers to join is expected as a parameter
When all workers joined and all have sent completed messages, this server also completes and exits
En example usage of JobMaster can be seen in: edu.iu.dsc.tws.rsched.schedulers.k8s.master.JobMasterStarter