Search before asking
What happened
Select "" as xx seems a wrong SQL in MyBatis, should change to Select '' as xx
|
<select id="queryWorkFlowLineageByCode" resultType="org.apache.dolphinscheduler.dao.entity.WorkFlowLineage"> |
|
select tepd.code as work_flow_code,tepd.name as work_flow_name, |
|
"" as source_work_flow_code, |
|
tepd.release_state as work_flow_publish_status, |
|
tes.start_time as schedule_start_time, |
|
tes.end_time as schedule_end_time, |
|
tes.crontab as crontab, |
|
tes.release_state as schedule_publish_status |
|
from t_ds_process_definition tepd |
|
left join t_ds_schedules tes on tepd.code = tes.process_definition_code |
|
where tepd.project_code = #{projectCode} and tepd.code = #{workFlowCode} |
|
</select> |
|
|
|
<select id="queryWorkFlowLineageByLineage" resultType="org.apache.dolphinscheduler.dao.entity.WorkFlowLineage"> |
|
select tepd.code as work_flow_code,tepd.name as work_flow_name, |
|
"" as source_work_flow_code, |
|
tepd.release_state as work_flow_publish_status, |
|
tes.start_time as schedule_start_time, |
|
tes.end_time as schedule_end_time, |
|
tes.crontab as crontab, |
|
tes.release_state as schedule_publish_status |
|
from t_ds_process_definition tepd |
|
left join t_ds_schedules tes on tepd.code = tes.process_definition_code |
|
where 1=1 |
|
<if test="processLineages != null and processLineages.size != 0"> |
|
and |
|
<foreach collection="processLineages" index="index" item="item" open="(" separator=" or " close=")"> |
|
(tepd.project_code = #{item.projectCode} |
|
and tepd.code = #{item.processDefinitionCode}) |
|
</foreach> |
|
</if> |
|
</select> |
What you expected to happen
Cannot run WorkFlowLineageMapper#queryWorkFlowLineageByCode.
How to reproduce
Execute WorkFlowLineageMapper#queryWorkFlowLineageByCode, WorkFlowLineageMapper#queryWorkFlowLineageByLineage
Anything else
See exception log
Are you willing to submit PR?
Code of Conduct
