edu.iu.dsc.tws.rsched.schedulers.k8s.master

Class JobMasterStarter

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.k8s.master.JobMasterStarter

public final class JobMasterStarter
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static JobAPI.Job	job

Method Summary

Modifier and Type	Method and Description
static boolean	initializeZooKeeper(Config config, java.lang.String jobID, java.lang.String jmAddress, JobMasterState initialState) Initialize zk directories if
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

job

public static JobAPI.Job job

Method Detail

main

public static void main(java.lang.String[] args)

initializeZooKeeper

public static boolean initializeZooKeeper(Config config,
                                          java.lang.String jobID,
                                          java.lang.String jmAddress,
                                          JobMasterState initialState)

Initialize zk directories if

Job Master is either starting for the first time, or it is coming from failure if it is coming from failure, update jm pers state, initialize eventCounter, read job object, return JobMasterState.JM_RESTARTED

if it is starting for the first time, create job directories at zk, create pers state znode for jm, return JobMasterState.JM_STARTED