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=")">

Reply via email to