flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jacky Du <jacky.du0...@gmail.com>
Subject Flink Table API schema doesn't support nested object in ObjectArray
Date Fri, 02 Aug 2019 14:01:21 GMT
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