[Bug] [SQL] SQL Task Node Custom Parameters run failed

[fhygh]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

when i using Custom Parameters of SQL Task Node with OUT type, sql query result is more than one row, in downstream sql using the parameters failed, if upstream sql result is one row, it work fine.
failed work flow:

work flow success

What you expected to happen

SQL Task Custom parameters work fine

How to reproduce

add two sql task node, in first node query select and add custom parameter OUT type, in donwstream sql using the parameters

Anything else

No response

Version

3.0.0-beta-1

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Thank you for your feedback, we have received your issue, Please wait patiently for a reply.

• In order for us to understand your request as soon as possible, please provide detailed information、version or pictures.
• If you haven't received a reply for a long time, you can join our slack and send your question to channel #troubleshooting

[fhygh]

here is the log:

[LOG-PATH]: /data/apache-dolphinscheduler-3.0.0-beta-1-bin/worker-server/logs/20220610/5803827748480_10-155-217.log, [HOST]: Host{address='xxxx:1234', ip='xxxx', port=1234}
[INFO] 2022-06-10 08:46:55.800 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[120] - Full sql parameters: SqlParameters{type='MYSQL', datasource=1, sql='select name from test.userinfo1 where name in (${name})', sqlType=0, sendEmail=null, displayRows=10, limit=0, segmentSeparator=, udfs='null', showType='null', connParams='null', groupId='0', title='null', preStatements=[], postStatements=[]}
[INFO] 2022-06-10 08:46:55.801 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[121] - sql type : MYSQL, datasource : 1, sql : select name from test.userinfo1 where name in (${name}) , localParams : [],udfs : null,showType : null,connParams : null,varPool : [Property{prop='name', direct=IN, type=LIST, value='["lisi","zhangsan"]'}] ,query max result limit 0
[INFO] 2022-06-10 08:46:55.802 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[91] - setSqlParamsMap: Property with paramName: name put in sqlParamsMap of content
select name from test.userinfo1 where name in (${name}) successfully.
[INFO] 2022-06-10 08:46:55.802 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[387] - after replace sql , preparing :
select name from test.userinfo1 where name in (?)
[INFO] 2022-06-10 08:46:55.802 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[396] - Sql Params are replaced sql , parameters:"lisi","zhangsan"
[INFO] 2022-06-10 08:46:55.802 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[465] - can't find udf function resource
[INFO] 2022-06-10 08:46:55.804 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[369] - prepare statement replace sql : HikariProxyPreparedStatement@1139720980 wrapping com.mysql.cj.jdbc.ClientPreparedStatement:
select name from test.userinfo1 where name in (** NOT SPECIFIED **)
[INFO] 2022-06-10 08:46:55.805 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[297] - main statement execute query, for sql:
select name from test.userinfo1 where name in (?)
[ERROR] 2022-06-10 08:46:55.805 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[213] - execute sql error: No value specified for parameter 1
[ERROR] 2022-06-10 08:46:55.805 +0800 [taskAppId=TASK-20220610-5803827748480_10-155-217] TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[164] - sql task error: java.sql.SQLException: No value specified for parameter 1

[stalary]

I can try to solve the problem.

[caishunfeng]

I can try to solve the problem.

Hi @stalary sorry for reply late, I had assigned to you.