From e912a8094c7226532e4ea9260a4ad1cfbd152f51 Mon Sep 17 00:00:00 2001
From: Zhou Zheng <1606079777@qq.comom>
Date: Sun, 26 Jul 2020 11:49:03 +0800
Subject: [PATCH] fix bug in mapper

---
 .../dolphinscheduler/dao/mapper/TaskInstanceMapper.xml      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 ebf446a0d8..8b654a2ec8 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
@@ -129,17 +129,17 @@
         </if>
         order by instance.start_time desc
     </select>
-    <select id="queryTasksByPIdAndStatesAndType">
+    <select id="queryTaskByPIdAndStateAndType" resultType="java.lang.Integer">
         select id from t_ds_task_instance
         where process_instance_id = #{processInstanceId}
         and task_type = #{taskType}
         and state = #{state}
         and flag = 1
     </select>
-    <select id="queryTasksBySubProcessTaskIdAndState">
+    <select id="queryTasksBySubProcessTaskIdAndState" resultType="java.lang.Integer">
         select id from t_ds_task_instance
         where process_instance_id =
-        (select process_instance_id in t_ds_relation_process_instance where parent_task_instance_id = #{subProcessTaskId})
+        (select process_instance_id from t_ds_relation_process_instance where parent_task_instance_id = #{subProcessTaskId})
         and state = #{state}
         and flag = 1
     </select>