diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
index 8bc91f7d7..5a6a085d2 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
@@ -15,7 +15,6 @@ import cn.axzo.workflow.core.engine.cmd.CustomBusinessNodeTimeoutCallbackCmd;
 import cn.axzo.workflow.core.engine.cmd.CustomBusinessNodeTimeoutTriggerCmd;
 import cn.axzo.workflow.core.service.BpmnProcessActivityService;
 import cn.axzo.workflow.core.service.ExtAxHiTaskInstService;
-import com.google.common.util.concurrent.Uninterruptibles;
 import lombok.extern.slf4j.Slf4j;
 import org.flowable.common.engine.impl.interceptor.CommandExecutor;
 import org.flowable.engine.RuntimeService;
@@ -27,7 +26,6 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import java.time.Duration;
 import java.util.Objects;
 
 import static cn.axzo.workflow.common.code.BpmnTaskRespCode.ACTIVITY_TRIGGER_NOT_EXISTS;
@@ -50,20 +48,10 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic
     @Transactional(rollbackFor = Exception.class)
     public void trigger(BpmnActivityTriggerDTO dto) {
         CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor();
-        try {
-            if (Boolean.TRUE.equals(dto.getAsync())) {
-                commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto));
-            } else {
-                commandExecutor.execute(new CustomActivityTriggerCmd(dto));
-            }
-        } catch (Exception e) {
-            log.info("trigger error msg: {}", e.getMessage(), e);
-            Uninterruptibles.sleepUninterruptibly(Duration.ofSeconds(2));
-            if (Boolean.TRUE.equals(dto.getAsync())) {
-                commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto));
-            } else {
-                commandExecutor.execute(new CustomActivityTriggerCmd(dto));
-            }
+        if (Boolean.TRUE.equals(dto.getAsync())) {
+            commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto));
+        } else {
+            commandExecutor.execute(new CustomActivityTriggerCmd(dto));
         }
     }