I am having an issue with the automatic type inference with SQL engine in an AsyncTableFunction class.
I am extending AsyncTableFunction<RowData> in a BaseClass (common code). Then extending again for some specific implementations. FinalClass extends BaseClass If I use BaseClass it correctly infers the output of the RowData from the catalog. If I use FinalClass it errors with Cannot extract a data type from an internal 'org.apache.flink.table.data.RowData' class without further information. Please use annotations to define the full logical type. So something with the typeInference is not looking at the right class in the hierarchy. I have tried overriding typeInformation at various points but it doesn't seem to help. Does anyone have an idea of how to have a common base class that gets extended with correct automatic typeinference? I can provide more details if needed.
