firstMasterSuccessTimeMap.put(jobId, System.currentTimeMillis());
} else {
if(System.currentTimeMillis() - initTime >= 2 * 60 * 1000L) {
killedSuccessJobSet.add(jobId);
killJob(controlledJob.getJob().getConfiguration(), jobId, "Kill job " + jobId
<BUG>+ "because of master is already finished, job " + jobId
</BUG>
+ " is treated as successful as we got models. ");
try {
Thread.sleep(1 * 1000L);

firstMasterSuccessTimeMap.put(jobId, System.currentTimeMillis());
} else {
if(System.currentTimeMillis() - initTime >= 2 * 60 * 1000L) {
killedSuccessJobSet.add(jobId);
killJob(controlledJob.getJob().getConfiguration(), jobId, "Kill job " + jobId
+ " because of master is already finished, job " + jobId
+ " is treated as successful as we got models. ");
try {
Thread.sleep(1 * 1000L);
