[jira] [Created] (FLINK-40391) PTF table argument with a non-default conversion class might fail

["Sergey Nuyanzin (Jira)" <ji...@apache.org>]

Sergey Nuyanzin created FLINK-40391:
---------------------------------------

             Summary: 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


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)