You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/06/10 14:23:18 UTC
[jira] [Created] (FLINK-6884) Incompatible
TableSource#getReturnType and actual input type should fail faster
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)