This is an automated email from the ASF dual-hosted git repository.
SbloodyS 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 51057477b8 [Improvement-18441][API&DAO] Optimize TaskInstanceMapper to
exclude large text fields from list queries (#18442)
51057477b8 is described below
commit 51057477b815eef59c68f1b76563567814c72a93
Author: suyc <[email protected]>
AuthorDate: Fri Aug 7 11:05:18 2026 +0800
[Improvement-18441][API&DAO] Optimize TaskInstanceMapper to exclude large
text fields from list queries (#18442)
---
.../dao/mapper/TaskInstanceMapper.xml | 22 +++++++++++++++++-----
1 file changed, 17 insertions(+), 5 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 674450ccbb..e632e7c9b3 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
@@ -30,6 +30,18 @@
${alias}.flag, ${alias}.retry_interval, ${alias}.max_retry_times,
${alias}.task_instance_priority,
${alias}.worker_group,${alias}.environment_code , ${alias}.executor_id,
${alias}.first_submit_time, ${alias}.delay_time, ${alias}.task_params,
${alias}.var_pool, ${alias}.dry_run, ${alias}.task_group_id,
${alias}.task_execute_type
</sql>
+ <sql id="listSql">
+ id, name, task_type, workflow_instance_id, workflow_instance_name,
project_code, task_code, task_definition_version, state, submit_time,
+ start_time, end_time, host, alert_flag, retry_times, pid, app_link,
+ flag, retry_interval, max_retry_times, task_instance_priority,
worker_group,environment_code , executor_id, executor_name,
+ first_submit_time, delay_time, dry_run, task_group_id, cpu_quota,
memory_max, task_execute_type
+ </sql>
+ <sql id="listSqlV2">
+ ${alias}.id, ${alias}.name, ${alias}.task_type,
${alias}.workflow_instance_id, ${alias}.workflow_instance_name,
${alias}.project_code, ${alias}.task_code, ${alias}.task_definition_version,
${alias}.state, ${alias}.submit_time,
+ ${alias}.start_time, ${alias}.end_time, ${alias}.host,
${alias}.alert_flag, ${alias}.retry_times, ${alias}.pid, ${alias}.app_link,
+ ${alias}.flag, ${alias}.retry_interval, ${alias}.max_retry_times,
${alias}.task_instance_priority, ${alias}.worker_group,
${alias}.environment_code, ${alias}.executor_id, ${alias}.executor_name,
+ ${alias}.first_submit_time, ${alias}.delay_time, ${alias}.dry_run,
${alias}.task_group_id, ${alias}.cpu_quota, ${alias}.memory_max,
${alias}.task_execute_type
+ </sql>
<select id="findValidTaskListByWorkflowInstanceId"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
<include refid="baseSql"/>
@@ -125,7 +137,7 @@
<select id="queryByInstanceIdAndCode"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
- <include refid="baseSql"/>
+ <include refid="listSql"/>
from t_ds_task_instance
where workflow_instance_id = #{workflowInstanceId}
and task_code = #{taskCode}
@@ -134,7 +146,7 @@
</select>
<select id="queryByWorkflowInstanceIdsAndTaskCodes"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
- <include refid="baseSql"/>
+ <include refid="listSql"/>
from t_ds_task_instance
where flag = 1
<if test="workflowInstanceIds != null and workflowInstanceIds.size()
!= 0">
@@ -153,7 +165,7 @@
<select id="queryTaskInstanceListPaging"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
- <include refid="baseSql"/>
+ <include refid="listSql"/>
from t_ds_task_instance
where project_code = #{projectCode}
<if test="startTime != null">
@@ -196,7 +208,7 @@
</select>
<select id="queryStreamTaskInstanceListPaging"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
- <include refid="baseSql"/>
+ <include refid="listSql"/>
from t_ds_task_instance
where project_code = #{projectCode}
<if test="startTime != null">
@@ -236,7 +248,7 @@
</select>
<select id="findLastTaskInstances"
resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
select
- <include refid="baseSqlV2">
+ <include refid="listSqlV2">
<property name="alias" value="instance"/>
</include>
from t_ds_task_instance instance
