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 <fhue...@gmail.com> 于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 <jacky.du0...@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 >> >
