diff --git a/src/main/java/com/kamco/cd/training/postgres/entity/ModelTrainJobEntity.java b/src/main/java/com/kamco/cd/training/postgres/entity/ModelTrainJobEntity.java
index 4be89a8..ceb4889 100644
--- a/src/main/java/com/kamco/cd/training/postgres/entity/ModelTrainJobEntity.java
+++ b/src/main/java/com/kamco/cd/training/postgres/entity/ModelTrainJobEntity.java
@@ -57,8 +57,7 @@ public class ModelTrainJobEntity {
   @Column(name = "exit_code")
   private Integer exitCode;
 
-  @Size(max = 2000)
-  @Column(name = "error_message", length = 2000)
+  @Column(name = "error_message", columnDefinition = "TEXT")
   private String errorMessage;
 
   @ColumnDefault("now()")
diff --git a/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java b/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java
index e889f21..ebfc16a 100644
--- a/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java
+++ b/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java
@@ -60,9 +60,9 @@ public class TrainJobWorker {
         totalEpoch = Integer.parseInt(params.get("totalEpoch").toString());
       }
     }
-
+    log.info("[JOB] markRunning start jobId={}, containerName={}", jobId, containerName);
     modelTrainJobCoreService.markRunning(jobId, containerName, null, "TRAIN_WORKER", totalEpoch);
-
+    log.info("[JOB] markRunning done jobId={}", jobId);
     try {
       TrainRunResult result;
 
@@ -109,6 +109,7 @@ public class TrainJobWorker {
         }
 
       } else {
+        String failMsg = result.getStatus() + "\n" + result.getLogs();
         modelTrainJobCoreService.markFailed(
             jobId, result.getExitCode(), result.getStatus() + "\n" + result.getLogs());