flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dawid Wysakowicz <wysakowicz.da...@gmail.com>
Subject Re: Stream sql example
Date Fri, 09 Jun 2017 18:19:41 GMT
Sorry forgot to add the link:

https://gist.github.com/dawidwys/537d12a6f2355cba728bf93f1af87b45

Z pozdrowieniami! / Cheers!

Dawid Wysakowicz

*Data/Software Engineer*

Skype: dawid_wys | Twitter: @OneMoreCoder

<http://getindata.com/>

2017-06-09 20:19 GMT+02:00 Dawid Wysakowicz <wysakowicz.dawid@gmail.com>:

> Hi,
> I tried writing a simple sql query with custom StreamTableSource and it
> fails with error:
>
> 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)
>>
>>
> You can check the source code here:
>
>
> Z pozdrowieniami! / Cheers!
>
> Dawid Wysakowicz
>
> *Data/Software Engineer*
>
> Skype: dawid_wys | Twitter: @OneMoreCoder
>
> <http://getindata.com/>
>

Mime
View raw message