diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go index d28120c2..a9699d30 100644 --- a/pkg/controller/queuejob/queuejob_controller_ex.go +++ b/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 {