diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java
index b6eecf9a7..268525071 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java
@@ -36,7 +36,7 @@ public abstract class AbstractExecuteWithLockJobHandler extends AbstractJobHandl
                 executeInternal(job, configuration, variableScope, commandContext);
             } else {
                 log.warn("get lock failed,processInstanceId:{},jobId:{}", processInstanceId, jobId);
-                throw new WorkflowEngineException(ASYNC_JOB_EXECUTION_ERROR);
+                throw new WorkflowEngineException(ASYNC_JOB_EXECUTION_ERROR, processInstanceId);
             }
         } finally {
             releaseLock(processInstanceId, jobId);
diff --git a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/AsyncElasticSearchSyncJobHandler.java b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/AsyncElasticSearchSyncJobHandler.java
index 119d47933..5780f7814 100644
--- a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/AsyncElasticSearchSyncJobHandler.java
+++ b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/AsyncElasticSearchSyncJobHandler.java
@@ -37,7 +37,6 @@ public class AsyncElasticSearchSyncJobHandler extends AbstractExecuteWithLockJob
         log.info("AsyncElasticSearchSyncJobHandler exec start...");
         ProcessEngineConfigurationImpl processEngineConfiguration =
                 CommandContextUtil.getProcessEngineConfiguration(commandContext);
-        String processInstanceId = job.getCustomValues();
-        processEngineConfiguration.getCommandExecutor().execute(new CustomElasticSearchCmd(processInstanceId, aggregateProcessInstanceService));
+        processEngineConfiguration.getCommandExecutor().execute(new CustomElasticSearchCmd(job.getProcessInstanceId(), aggregateProcessInstanceService));
     }
 }
diff --git a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/CustomElasticSearchAsyncCmd.java b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/CustomElasticSearchAsyncCmd.java
index 3573f1620..333042933 100644
--- a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/CustomElasticSearchAsyncCmd.java
+++ b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/flowable/ext/CustomElasticSearchAsyncCmd.java
@@ -51,10 +51,10 @@ public class CustomElasticSearchAsyncCmd extends AbstractCommand<Void> implement
         String jobId = startAsync(processEngineConfiguration, instance);
 
 //        // 重置任务，因为上面的 cmd 和这个 cmd 的 lock 对象不一致
-//        JobServiceConfiguration jobServiceConfiguration = processEngineConfiguration.getJobServiceConfiguration();
-//        CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor();
-//        CommandConfig commandConfig = new CommandConfig().transactionRequired();
-//        commandExecutor.execute(commandConfig, new ResetExpiredJobsCmd(Collections.singletonList(jobId), jobServiceConfiguration.getJobEntityManager(), jobServiceConfiguration));
+        JobServiceConfiguration jobServiceConfiguration = processEngineConfiguration.getJobServiceConfiguration();
+        CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor();
+        CommandConfig commandConfig = new CommandConfig().transactionRequired();
+        commandExecutor.execute(commandConfig, new ResetExpiredJobsCmd(Collections.singletonList(jobId), jobServiceConfiguration.getJobEntityManager(), jobServiceConfiguration));
         return null;
     }
 
@@ -71,11 +71,8 @@ public class CustomElasticSearchAsyncCmd extends AbstractCommand<Void> implement
         job.setJobHandlerType(AsyncElasticSearchSyncJobHandler.TYPE);
         job.setTenantId(instance.getTenantId());
 
-        // 携带自定义的数据
-        job.setCustomValues(processInstanceId);
-
         // 创建异步任务并调度
-        jobService.createAsyncJob(job, false);
+        jobService.createAsyncJob(job, true);
         jobService.scheduleAsyncJob(job);
         return job.getId();
     }