diff --git a/component/clusterd/pkg/domain/job/job_cm_util.go b/component/clusterd/pkg/domain/job/job_cm_util.go
index bcfde0f0a16e9816463b2e9cd0de299ddce540c9..d15f244ab7570b1f5fc49ad83a8dcb1ce1b49979 100644
--- a/component/clusterd/pkg/domain/job/job_cm_util.go
+++ b/component/clusterd/pkg/domain/job/job_cm_util.go
@@ -44,6 +44,9 @@ func initCM(jobInfo constant.JobInfo) bool {
 	data[jobName] = jobInfo.Name
 	data[frameWorkKey] = jobInfo.Framework
 	data[jobId] = jobInfo.Key
+	if jobInfo.CustomJobID != "" {
+		data[CustomJobID] = jobInfo.CustomJobID
+	}
 	data[jobStatus] = jobInfo.Status
 	data[cmIndex] = "0"
 	data[cmCutNumKey] = strconv.Itoa(jobInfo.TotalCmNum)
@@ -67,6 +70,9 @@ func updateCM(jobInfo constant.JobInfo, index int, hccl string) bool {
 	data[jobName] = jobInfo.Name
 	data[frameWorkKey] = jobInfo.Framework
 	data[jobId] = jobInfo.Key
+	if jobInfo.CustomJobID != "" {
+		data[CustomJobID] = jobInfo.CustomJobID
+	}
 	data[jobStatus] = jobInfo.Status
 	data[addTime] = strconv.Itoa(int(jobInfo.AddTime))
 	data[configmapOperator] = operatorAdd
@@ -101,6 +107,9 @@ func preDeleteCM(jobInfo constant.JobInfo, hccls []string) bool {
 	data[frameWorkKey] = jobInfo.Framework
 	data[jobStatus] = jobInfo.Status
 	data[jobId] = jobInfo.Key
+	if jobInfo.CustomJobID != "" {
+		data[CustomJobID] = jobInfo.CustomJobID
+	}
 	data[HcclJson] = defaultHcclJson
 	data[configmapOperator] = operatorDelete
 	data[deleteTime] = strconv.Itoa(int(jobInfo.DeleteTime))