修复client日志打印报错

common/assets/confs/client.config.json

@@ -1,6 +1,8 @@
 {
     "logger": {
-        "output": "stdout",
+        "output": "file",
+        "outputFileName": "schedulerclient",
+        "outputDirectory": "log",
         "level": "debug"
     },
     "rabbitMQ": {

manager/internal/jobmgr/job/state/multiInstance_init.go

@@ -3,7 +3,6 @@ package state
 import (
 	"context"
 	"fmt"
-	"gitlink.org.cn/cloudream/common/pkgs/logger"
 	schsdk "gitlink.org.cn/cloudream/common/sdks/scheduler"
 	jobmod "gitlink.org.cn/cloudream/scheduler/common/models/job"
 	"gitlink.org.cn/cloudream/scheduler/common/pkgs/prescheduler"
@@ -54,13 +53,11 @@ func (s *MultiInstanceInit) do(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job) {
 	// 创建实例并运行
 	instanceJob := job.NewInstanceJob(*instJobInfo, files)
 	jobID := rtx.Mgr.AddJob(jo.JobSetID, instanceJob, NewPreSchuduling(multInstJob.PreScheduler))
-	logger.Info("Init instance success, jobID: " + jobID)
 
 	// 在多实例任务中新增这个实例的任务ID
 	multInstJob.SubJobs = append(multInstJob.SubJobs, jobID)
 
 	rtx.Mgr.ChangeState(jo, NewMultiInstanceRunning(prescheduler.NewDefaultPreScheduler()))
-	logger.Info("Create multiInstance job success, jobID: " + jo.JobID)
 }
 
 func (s *MultiInstanceInit) Dump(ctx jobmgr.JobStateRunContext, job *jobmgr.Job) jobmod.JobStateDump {

manager/internal/jobmgr/job/state/multiInstance_running.go

@@ -28,7 +28,6 @@ func (s *MultiInstanceRunning) Run(rtx jobmgr.JobStateRunContext, job *jobmgr.Jo
 }
 
 func (s *MultiInstanceRunning) do(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job) {
-	logger.Info("start run multiInstanceRunning, jobID: " + jo.JobID)
 
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -81,7 +80,6 @@ func (s *MultiInstanceRunning) do(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job)
 		// 创建实例并运行
 		instanceJob := job.NewInstanceJob(*instJobInfo, files)
 		jobID := rtx.Mgr.AddJob(jo.JobSetID, instanceJob, NewPreSchuduling(*jobSchedule))
-		logger.Info("Create instance success, jobID: " + jobID)
 
 		// 在多实例任务中新增这个实例的任务ID
 		multInstJob.SubJobs = append(multInstJob.SubJobs, jobID)

manager/internal/jobmgr/jobmgr.go

@@ -74,6 +74,7 @@ func (m *Manager) ChangeState(job *Job, state JobState) {
 
 	lastState := mgrJob.state
 	mgrJob.state = state
+	logger.Info("jobID: %s change state from %s to %s", job.JobID, lastState, state)
 
 	go func() {
 		state.Run(JobStateRunContext{

manager/internal/mq/job.go

@@ -48,7 +48,6 @@ func (svc *Service) SubmitJobSet(msg *mgrmq.SubmitJobSet) (*mgrmq.SubmitJobSetRe
 
 		case *schsdk.MultiInstanceJobInfo:
 			preSch, ok := msg.PreScheduleScheme.JobSchemes[info.LocalJobID]
-			logger.Info(">>>localJobID: " + info.LocalJobID)
 
 			job := job.NewMultiInstanceJob(*info, preSch)