diff --git a/src/common/backend/catalog/pg_job.cpp b/src/common/backend/catalog/pg_job.cpp
index 9a98ea28e08ee7cecd56a67ac6ff1021dcfdeda8..256e436c8a36f35df4a63ff13c96d85ca0e1d005 100644
--- a/src/common/backend/catalog/pg_job.cpp
+++ b/src/common/backend/catalog/pg_job.cpp
@@ -1929,8 +1929,12 @@ void update_run_job_to_fail()
     while (HeapTupleIsValid(tuple = heap_getnext(scan, ForwardScanDirection))) {
         Form_pg_job pg_job = (Form_pg_job)GETSTRUCT(tuple);
         /* Every coordinator should update all tuples which job_status is 'r'. */
+#ifdef ENABLE_MULTIPLE_NODES
         if (pg_job->job_status == PGJOB_RUN_STATUS &&
             0 == strcmp(pg_job->node_name.data, g_instance.attr.attr_common.PGXCNodeName)) {
+#else
+        if (pg_job->job_status == PGJOB_RUN_STATUS) {
+#endif
             get_job_values(pg_job->job_id, tuple, pg_job_tbl, old_value, visnull);
             values[Anum_pg_job_failure_count - 1] = Int16GetDatum(pg_job->failure_count + 1);
 
diff --git a/src/gausskernel/process/job/job_scheduler.cpp b/src/gausskernel/process/job/job_scheduler.cpp
index b823edec4145bb6583728a0ed14561544a4dfee8..e7e6510388b65f8362d19dbfd90796a5d94cccbb 100755
--- a/src/gausskernel/process/job/job_scheduler.cpp
+++ b/src/gausskernel/process/job/job_scheduler.cpp
@@ -734,10 +734,12 @@ static void ScanExpireJobs()
             continue;
         }
 
+#ifdef ENABLE_MULTIPLE_NODES
         /* handle cases - ALL_NODE/ALL_CN/ALL_DN/CCN specific node */
         if (!IsExecuteOnCurrentNode(pg_job->node_name.data)) {
             continue;
         }
+#endif
 
         Datum cur_job_start_time = DirectFunctionCall1(timestamp_timestamptz, values[Anum_pg_job_next_run_date - 1]);
         if (false == DatumGetBool(DirectFunctionCall2(timestamp_gt, curtime, cur_job_start_time))) {