Flink Table API schema doesn't support nested object in ObjectArray

[Jacky Du]

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

[Fabian Hueske-2]

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 <[hidden email]>:

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

[Jacky Du]

thanks Fabian , I created a Jira ticket with a code sample . 

https://issues.apache.org/jira/projects/FLINK/issues/FLINK-13603?filter=allopenissues

I think if the root cause I found is correct, fix this issue could be pretty simple . 

Thanks 

Jacky Du

Fabian Hueske <[hidden email]> 于2019年8月2日周五 下午12:07写道：

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 <[hidden email]>:

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

[Fabian Hueske-2]

Great, thank you!

Am Do., 8. Aug. 2019 um 02:15 Uhr schrieb Jacky Du <[hidden email]>:

thanks Fabian , I created a Jira ticket with a code sample . 

https://issues.apache.org/jira/projects/FLINK/issues/FLINK-13603?filter=allopenissues

I think if the root cause I found is correct, fix this issue could be pretty simple . 

Thanks 

Jacky Du

Fabian Hueske <[hidden email]> 于2019年8月2日周五 下午12:07写道：

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 <[hidden email]>:

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