From 65d3e01ff3067ee163d498bad26a029f0c134653 Mon Sep 17 00:00:00 2001
From: wangwq10 <125749333@qq.com>
Date: Fri, 23 May 2025 16:12:23 +0800
Subject: [PATCH] fix: after pause is called successfully, status/state should
 align to job.State that can return "paused" as excepted.

---
 pkg/ccr/job_manager.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/ccr/job_manager.go b/pkg/ccr/job_manager.go
index 174e4ee4..31abd4f2 100644
--- a/pkg/ccr/job_manager.go
+++ b/pkg/ccr/job_manager.go
@@ -217,6 +217,8 @@ func (jm *JobManager) GetJobStatus(jobName string) (*JobStatus, error) {
 	defer jm.lock.RUnlock()
 
 	if job, ok := jm.jobs[jobName]; ok {
+		log.Debugf("job rawStatue: %s, job state:%s", job.rawStatus.state, job.State)
+		atomic.StoreInt32(&job.rawStatus.state, int32(job.State))
 		return job.Status(), nil
 	} else {
 		return nil, xerror.Errorf(xerror.Normal, "job not exist: %s", jobName)