[FLINK-17683] Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class.

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.10.1
• Fix Version/s: 1.20.0
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major auto-unassigned
• Assignee: Unassigned
• Reporter: xiemeilong
• Created: 14/May/20 05:51
• Updated: 11/Mar/24 12:44

Description

Pojo.java

@Data
@NoArgsConstructor
public class Pojo  {
    private String foo;
}

object Fun extends ScalarFunction { 
   def eval(): Pojo = { new Pojo() } 
}
case class CaseClass(pojo:Pojo)

 

 

tableEnv.registerFunction("fun", Fun)
val table = tableEnv.sqlQuery("select fun() as pojo")
table.toRetractStream[CaseClass].print()

 

exception:

 

Exception in thread "main" org.apache.flink.table.api.ValidationException: Field types of query result and registered TableSink  do not match.
Query schema: [pojo: ROW<`foo` STRING>]
Sink schema: [pojo: LEGACY('STRUCTURED_TYPE', 'POJO<com.yunmo.iot.Pojo>')]