sd4324530 commented on issue #2270:
URL: https://github.com/apache/fluss/issues/2270#issuecomment-3696945175
@wuchong I tested “Option B”, changing the parameters to an array, which
worked in Flink 1.18, but failed in Flink 1.19.
The API may have been adjusted, and this issue has not yet been resolved.
code:
`
@ProcedureHint(
argument = {
@ArgumentHint(name = "config_pairs", type =
@DataTypeHint("ARRAY<STRING>"))
})
public String[] call(ProcedureContext context, String... configPairs)
throws Exception
`
error:
`
org.apache.flink.table.api.ValidationException: SQL validation failed. SQL
validation failed. From line 1, column 22 to line 1, column 96: No match found
for function signature set_cluster_config(<CHARACTER>, <CHARACTER>).
Supported signatures are:
set_cluster_config(config_pairs => ARRAY<STRING>)
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:200)
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:117)
at
org.apache.flink.table.planner.operations.SqlNodeToOperationConversion.convert(SqlNodeToOperationConversion.java:259)
at
org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:106)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:728)
at
org.apache.fluss.flink.procedure.FlinkProcedureITCase.testSetClusterConfig(FlinkProcedureITCase.java:318)
`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
