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
