Dawid Wysakowicz created FLINK-6884: ---------------------------------------
Summary: Incompatible TableSource#getReturnType and actual input type should fail faster Key: FLINK-6884 URL: https://issues.apache.org/jira/browse/FLINK-6884 Project: Flink Issue Type: Bug Components: Table API & SQL Affects Versions: 1.3.0 Reporter: Dawid Wysakowicz When a {{TableSource#getReturnType}} differs from the actual input type the exception is thrown in code generation step with an exception that is hard to track back: {code} org.apache.flink.table.codegen.CodeGenException: Arity of result type does not match number of expressions. at org.apache.flink.table.codegen.CodeGenerator.generateResultExpression(CodeGenerator.scala:940) at org.apache.flink.table.codegen.CodeGenerator.generateConverterResultExpression(CodeGenerator.scala:883) at org.apache.flink.table.plan.nodes.CommonScan$class.generatedConversionFunction(CommonScan.scala:57) at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan.generatedConversionFunction(StreamTableSourceScan.scala:35) at org.apache.flink.table.plan.nodes.datastream.StreamScan$class.convertToInternalRow(StreamScan.scala:48) at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan.convertToInternalRow(StreamTableSourceScan.scala:35) at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan.translateToPlan(StreamTableSourceScan.scala:107) {code} It would be nice if more meaningful exception was thrown earlier. -- This message was sent by Atlassian JIRA (v6.3.15#6346)