flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Flink Table API schema doesn't support nested object in ObjectArray
Date Fri, 02 Aug 2019 16:06:40 GMT
Thanks for the bug report Jacky!

Would you mind opening a Jira issue, preferably with a code snippet that
reproduces the bug?

Thank you,
Fabian

Am Fr., 2. Aug. 2019 um 16:01 Uhr schrieb Jacky Du <jacky.du0314@gmail.com>:

> Hi, All
>
> Just find that Flink Table API have some issue if define nested object in
> an object array . it will give column not found exception if a table schema
> define like below :
>
> payload : Row(arraylist : ObjectArrayTypeInfo<Row(inner : Row(attr :
> String))>)
>
> but Table APi works fine if we don't have nested object in array , so
> below one is working :
>
> payload : Row(arraylist : ObjectArrayTypeInfo<Row(inner : String)>)
>
>
> This issue happens at 1.6.x , 1.7.x and 1.8.x ,  but working at 1.5.x .
>
>
> Thanks
> Jacky Du
>

Mime
View raw message