[Bug] Searching for variables in streampark installed by postgresql report error

[DimitriMok]

Search before asking

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

Java Version

1.8

Scala Version

2.12.x

StreamPark Version

2.1.2

Flink Version

1.15.3

deploy mode

kubernetes-application

What happened

We have installed streampark based on postgresql. Howerver, we found an error as following when searching for variables. There are some problems in page query variables by regexp match, but the version before 2.1.1 has nothing. By study source code, the sql changed from "'%${variable.variableCode}%'" to "concat ('%', #{variable.variableCode}, '%')" is not compatible with postgresql, though that can prevent the sql injection and compatible with mysql.

Error Exception

internal server error: ### Error querying database. Cause: org.postgresql.util.PSQLException: ERROR: could not determine data type of parameter $2 ### The error may exist in class path resource [mapper/core/VariableMapper.xml] ### The error may involve org.apache.streampark.console.core.mapper.VariableMapper.page-Inline ### The error occurred while setting parameters ### SQL: select count(*) as total from t_variable v inner join t_user u on v.creator_id = u.user_id and v.team_id = ? and v.variable_code like concat('%', ?, '%') ### Cause: org.postgresql.util.PSQLException: ERROR: could not determine data type of parameter $2 ; bad SQL grammar []; nested exception is org.postgresql.util.PSQLException: ERROR: could not determine data type of parameter $2

Screenshots

Are you willing to submit PR?

• Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

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

[caicancai]

Thank you for your feedback, we will try to fix this issue

[caicancai]

@wolfboys @RocMarshal This question looks like a good first issue, what do you think?

[VampireAchao]

assign me