diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java index bca2d4bbf70f..0b47c20eb00f 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java @@ -121,6 +121,8 @@ public void handle(TaskCallBack taskCallBack) throws TaskException { // print the output parameters to the log printOutParameter(tmpStatement, outParameterMap); + // set varPool + taskExecutionContext.setVarPool(procedureParameters.getVarPool()); setExitStatusCode(EXIT_CODE_SUCCESS); } } catch (Exception e) {