diff --git a/rule-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java b/rule-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java
index 9f46f85..197774e 100644
--- a/rule-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java
+++ b/rule-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java
@@ -65,7 +65,7 @@ public AbstractExecutionContext(String workerId,
         this.eventOutputs = eventOutputs
                 .entrySet()
                 .stream()
-                .collect(Collectors.toMap(Map.Entry::getKey, e -> RuleEngineHooks.wrapOutput(output)));
+                .collect(Collectors.toMap(Map.Entry::getKey, e -> RuleEngineHooks.wrapOutput(e.getValue())));
         this.logger = CompositeLogger.of(logger, new EventLogger(eventBus, job.getInstanceId(), job.getNodeId(), workerId));
         this.globalScope = globalScope;
     }