[
https://issues.apache.org/jira/browse/FLINK-40391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-40391.
-------------------------------------
Fix Version/s: 2.4.0
Resolution: Fixed
> PTF table argument with a non-default conversion class might fail
> -----------------------------------------------------------------
>
> Key: FLINK-40391
> URL: https://issues.apache.org/jira/browse/FLINK-40391
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Sergey Nuyanzin
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.4.0
>
>
> example
> {code:java}
> StaticArgument.table(
> "input",
> RowData.class,
> false,
> EnumSet.of(StaticArgumentTrait.ROW_SEMANTIC_TABLE))
> {code}
>
> then call to such PTF will fail as
> {noformat}
> org.apache.flink.table.api.ValidationException: Could not find an
> implementation method 'eval' in class
> 'org.apache.flink.table.planner.plan.nodes.exec.stream.ProcessTableFunctionTestUtils$RowDataRowSemanticTableFunction'
> for function 'f' that matches the following signature:
> void eval(org.apache.flink.types.Row)
> at
> org.apache.flink.table.functions.UserDefinedFunctionHelper.validateClassForRuntime(UserDefinedFunctionHelper.java:347)
> at
> org.apache.flink.table.planner.codegen.ProcessTableRunnerGenerator$.verifyMethodImplementation(ProcessTableRunnerGenerator.scala:405)
> at
> org.apache.flink.table.planner.codegen.ProcessTableRunnerGenerator$.generateEvalCode(ProcessTableRunnerGenerator.scala:442)
> at
> org.apache.flink.table.planner.codegen.ProcessTableRunnerGenerator$.generate(ProcessTableRunnerGenerator.scala:153)
> at
> org.apache.flink.table.planner.codegen.ProcessTableRunnerGenerator.generate(ProcessTableRunnerGenerator.scala)
> at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecProcessTableFunction.translateToPlanInternal(StreamExecProcessTableFunction.java:217)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:195)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:262)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
