diff --git a/schedulerMiddleware/internal/manager/jobmgr/job/state2/data_schedule_binding.go b/schedulerMiddleware/internal/manager/jobmgr/job/state2/data_schedule_binding.go index f13cf28..97674eb 100644 --- a/schedulerMiddleware/internal/manager/jobmgr/job/state2/data_schedule_binding.go +++ b/schedulerMiddleware/internal/manager/jobmgr/job/state2/data_schedule_binding.go @@ -627,7 +627,7 @@ func (s *DataScheduleAndBinding) normalBinding(rtx jobmgr.JobStateRunContext, jo if err != nil { return nil, cacheName, err } - jsonData, err = json.Marshal(resp) + jsonData, err = json.Marshal(resp.Data) if err != nil { return nil, cacheName, err } diff --git a/schedulerMiddleware/internal/manager/jobmgr/job/state2/pcm_job_create.go b/schedulerMiddleware/internal/manager/jobmgr/job/state2/pcm_job_create.go index 10f5d07..8e96e61 100644 --- a/schedulerMiddleware/internal/manager/jobmgr/job/state2/pcm_job_create.go +++ b/schedulerMiddleware/internal/manager/jobmgr/job/state2/pcm_job_create.go @@ -85,7 +85,7 @@ func (s *PCMJobCreate) Run(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job) { if data.DataType == sch.IMAGE { s.task.Send(sch.TaskMessage{ Status: sch.FailedStatus, - Message: "image cannot schedule", + Message: "Image cannot be scheduled", }) rtx.Mgr.ChangeState(jo, FailureComplete(fmt.Errorf("missing image, cluster: %v", data.ClusterIDs))) return diff --git a/schedulerMiddleware/internal/services/app.go b/schedulerMiddleware/internal/services/app.go index 0d1b783..348e719 100644 --- a/schedulerMiddleware/internal/services/app.go +++ b/schedulerMiddleware/internal/services/app.go @@ -379,7 +379,7 @@ func (svc *AppService) appInfoHandle(appInfos []schsdk.AppInfo, param AppSubmitP if err != nil { return nil, nil, "", err } - msg = fmt.Sprintf("{bindingID: %v}", bindingID) + msg = fmt.Sprintf("{\"bindingID\": %v}", bindingID) } } return jobs, recordParams, msg, nil