Update queuejob_controller_ex.go (#581)

Author: eranra

Diff for: pkg/controller/queuejob/queuejob_controller_ex.go

@@ -245,8 +245,11 @@ func NewJobController(config *rest.Config, serverOption *options.ServerOption) *
 	cc.agentList = []string{}
 	for _, agentconfig := range strings.Split(serverOption.AgentConfigs, ",") {
 		agentData := strings.Split(agentconfig, ":")
-		cc.agentMap["/root/kubernetes/"+agentData[0]] = queuejobdispatch.NewJobClusterAgent(agentconfig, cc.agentEventQueue)
-		cc.agentList = append(cc.agentList, "/root/kubernetes/"+agentData[0])
+		jobClusterAgent := queuejobdispatch.NewJobClusterAgent(agentconfig, cc.agentEventQueue)
+		if jobClusterAgent != nil {
+			cc.agentMap["/root/kubernetes/"+agentData[0]] = jobClusterAgent
+			cc.agentList = append(cc.agentList, "/root/kubernetes/"+agentData[0])
+		}		
 	}
 
 	if cc.isDispatcher && len(cc.agentMap) == 0 {