diff --git a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
index 4bbc9d4..21f98ad 100644
--- a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
+++ b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
@@ -45,6 +45,7 @@ public class ModelTrainJobCoreService {
     job.setQueuedDttm(queuedDttm != null ? queuedDttm : ZonedDateTime.now());
 
     modelTrainJobRepository.save(job);
+    modelTrainJobRepository.flush();
     return job.getId();
   }
 
diff --git a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
index 9e967ac..8861649 100644
--- a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
+++ b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
@@ -312,6 +312,7 @@ public class ModelTrainMngCoreService {
     master.setCurrentAttemptId(jobId);
 
     // 필요하면 시작시간도 여기서 찍어줌
+    modelMngRepository.flush();
   }
 
   /** 마지막 에러 메시지 초기화 - 재시작/새 실행 때 이전 에러 흔적 제거 */
@@ -323,6 +324,7 @@ public class ModelTrainMngCoreService {
             .orElseThrow(() -> new IllegalArgumentException("Model not found: " + modelId));
 
     master.setLastError(null);
+    modelMngRepository.flush();
   }
 
   /** 중단 처리(옵션) - cancel에서 쓰려고 하면 같이 구현 */