This is an automated email from the ASF dual-hosted git repository.
zihaoxiang 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 84912169de [Fix-17182][Dependent Task] error occured in dependent task
node (#17183)
84912169de is described below
commit 84912169de1caff2bdb2785774d643116db6e9ee
Author: xiangzihao <[email protected]>
AuthorDate: Fri May 16 10:50:26 2025 +0800
[Fix-17182][Dependent Task] error occured in dependent task node (#17183)
---
.../apache/dolphinscheduler/dao/mapper/TaskInstanceContextMapper.xml | 2 +-
.../org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceContextMapper.xml
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceContextMapper.xml
index 04f7e2080c..14958ba815 100644
---
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceContextMapper.xml
+++
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceContextMapper.xml
@@ -39,7 +39,7 @@
AND context_type = #{contextType}
</delete>
- <update id="updateByTaskInstanceId">
+ <update id="updateTaskInstanceContextByTaskInstanceIdAndContextType">
UPDATE t_ds_task_instance_context
SET
context = #{context}
diff --git
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
index 5f7ba908b9..6cf12d8e03 100644
---
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
+++
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
@@ -245,7 +245,7 @@
select task_code, max(end_time) as max_end_time
from t_ds_task_instance
where 1=1 and test_flag = #{testFlag}
- and instance.workflow_instance_id = #{workflowInstanceId}
+ and workflow_instance_id = #{workflowInstanceId}
<if test="taskCodes != null and taskCodes.size() != 0">
and task_code in
<foreach collection="taskCodes" index="index" item="i" open="("
separator="," close=")">