[
https://issues.apache.org/jira/browse/FLINK-40391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18104844#comment-18104844
]
Sergey Nuyanzin commented on FLINK-40391:
-----------------------------------------
Merged as
[3c930cb20830d836bea7371ca2d76160b8c4169b|https://github.com/apache/flink/commit/3c930cb20830d836bea7371ca2d76160b8c4169b]
> 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
>
> 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)
