fix(alarm): task alarm add exception message (#3004)

* fix

* fix

Author: ungreat

server/odc-service/src/main/java/com/oceanbase/odc/service/task/schedule/daemon/DestroyExecutorJob.java

@@ -82,8 +82,8 @@ private void destroyExecutor(TaskFrameworkService taskFrameworkService, JobEntit
                     if (e.getMessage() != null &&
                             !e.getMessage().startsWith(JobConstants.ODC_EXECUTOR_CANNOT_BE_DESTROYED)) {
                         AlarmUtils.alarm(AlarmEventNames.TASK_EXECUTOR_DESTROY_FAILED,
-                                MessageFormat.format("Job executor destroy failed, jobId={0}",
-                                        lockedEntity.getId()));
+                                MessageFormat.format("Job executor destroy failed, jobId={0}, message={1}",
+                                        lockedEntity.getId(), e.getMessage()));
                     }
                     throw new TaskRuntimeException(e);
                 }

server/odc-service/src/main/java/com/oceanbase/odc/service/task/schedule/daemon/DoCancelingJob.java

@@ -87,7 +87,8 @@ private void cancelJob(TaskFrameworkService taskFrameworkService, JobEntity jobE
                 } catch (JobException e) {
                     log.warn("Stop job occur error: ", e);
                     AlarmUtils.alarm(AlarmEventNames.TASK_CANCELED_FAILED,
-                            MessageFormat.format("Cancel job failed, jobId={0}", lockedEntity.getId()));
+                            MessageFormat.format("Cancel job failed, jobId={0}, message={1}", lockedEntity.getId(),
+                                    e.getMessage()));
                     throw new TaskRuntimeException(e);
                 }
                 log.info("Job be cancelled successfully, jobId={}, oldStatus={}.", lockedEntity.getId(),

server/odc-service/src/main/java/com/oceanbase/odc/service/task/schedule/daemon/StartPreparingJob.java

@@ -113,7 +113,8 @@ private void startJob(TaskFrameworkService taskFrameworkService, JobEntity jobEn
                     getConfiguration().getJobDispatcher().start(jc);
                 } catch (JobException e) {
                     AlarmUtils.alarm(AlarmEventNames.TASK_START_FAILED,
-                            MessageFormat.format("Start job failed, jobId={0}", lockedEntity.getId()));
+                            MessageFormat.format("Start job failed, jobId={0}, message={1}", lockedEntity.getId(),
+                                    e.getMessage()));
                     throw new TaskRuntimeException(e);
                 }
             } else {

server/odc-service/src/main/java/com/oceanbase/odc/service/task/service/StdTaskFrameworkService.java

@@ -47,6 +47,7 @@
 import com.oceanbase.odc.common.event.EventPublisher;
 import com.oceanbase.odc.common.jpa.SpecificationUtil;
 import com.oceanbase.odc.common.json.JsonUtils;
+import com.oceanbase.odc.common.security.SensitiveDataUtils;
 import com.oceanbase.odc.common.trace.TraceContextHolder;
 import com.oceanbase.odc.common.util.StringUtils;
 import com.oceanbase.odc.common.util.SystemUtils;
@@ -329,8 +330,9 @@ public void handleResult(TaskResult taskResult) {
                         .publishEvent(new JobTerminateEvent(taskResult.getJobIdentity(), taskResult.getStatus())));
                 if (taskResult.getStatus() == JobStatus.FAILED) {
                     AlarmUtils.alarm(AlarmEventNames.TASK_EXECUTION_FAILED,
-                            MessageFormat.format("Job execution failed, jobId={0}",
-                                    taskResult.getJobIdentity().getId()));
+                            MessageFormat.format("Job execution failed, jobId={0}, resultJson={1}",
+                                    taskResult.getJobIdentity().getId(),
+                                    SensitiveDataUtils.mask(taskResult.getResultJson())));
                 }
             }
         }