apache/dolphinscheduler

[Bug] When contains multiple sub-processes, the task instance in the sub-process instance obtains duplicate parameters of the pre-task instance.

Open

#16,879 创建于 2024年12月5日

在 GitHub 查看
 (13 评论) (0 反应) (0 负责人)Java (11,659 star) (4,324 fork)batch import
bughelp wanted

描述

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

在工作流中，创建多个子流程，例如创建12个子流程，子流程在获取上游任务参数时，会出现覆盖/错误/以及12个节点拿到的参数完全一致，这不符合预期 通过数据库中查询来看，生成的12的子流程实例，参数没有问题，但是在varpool的设置阶段，获取parent_process_instance_id所对应的varpool，是相同的，这导致子流程实例中的任务实例，执行时的参数永远是相同的

What you expected to happen

通过数据库中查询来看，生成的12的子流程实例，参数没有问题，但是在varpool的设置阶段，获取parent_process_instance_id所对应的varpool，是相同的，这导致子流程实例中的任务实例，执行时的参数永远是相同的 通过debug setSubProcessParam这个方法，能够看出每个子流程任务实例获取到的varpool参数都有问题，并且会随机出现重复

How to reproduce

我已经验证了3.2.1的standalone镜像，3.2.2的standalone镜像，debug镜像代码，都存在此问题，也可以在这两个镜像web服务页面，复现。我提供了我的验证工作流json，⚠️注意：导入后需要更改主流程中子流程的引用为新的id workflow_1733366901095.json

Anything else

No response

Version

3.2.x

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

贡献者指南

技术栈
java
领域
backenddata
议题类型
bug
难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。
4
预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。
3-5 days
活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。
active
清晰度议题是否清楚说明期望改动、验收标准和下一步。
clear
前置要求
JavaDolphinScheduler basicsDebugging
新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。
35
研究方向
Start by examining the setSubProcessParam method in the sub process task executor. The issue indicates that varpool retrieval uses parent process instance id leading to duplicate parameters. Investigate how multiple sub process instances are identified and ensure each sub process fetches its own varpool. Consider adding unit tests to verify parameter isolation across concurrent sub processes.