You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2026/02/11 02:20:50 UTC

(dolphinscheduler) branch dev updated: [Fix-17967] Fix Parameter passing feature is unavailable in Procedure Task (#17968)

This is an automated email from the ASF dual-hosted git repository.

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 113430ab66 [Fix-17967] Fix Parameter passing feature is unavailable in Procedure Task (#17968)
113430ab66 is described below

commit 113430ab661c82d9dd4b9d343acb93e6bb3a0df9
Author: huangsheng <hu...@163.com>
AuthorDate: Wed Feb 11 10:20:44 2026 +0800

    [Fix-17967] Fix Parameter passing feature is unavailable in Procedure Task (#17968)
---
 .../apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java    | 2 ++
 1 file changed, 2 insertions(+)

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 bca2d4bbf7..0b47c20eb0 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 class ProcedureTask extends AbstractTask {
                 // print the output parameters to the log
                 printOutParameter(tmpStatement, outParameterMap);
 
+                // set varPool
+                taskExecutionContext.setVarPool(procedureParameters.getVarPool());
                 setExitStatusCode(EXIT_CODE_SUCCESS);
             }
         } catch (Exception e) {