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

[Sergey Nuyanzin (Jira)]

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)