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

2019-08-07 Thread 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 于2019年8月2日周五 下午12:07写道

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

2019-08-02 Thread Jacky Du
below one is working : payload : Row(arraylist : ObjectArrayTypeInfo) This issue happens at 1.6.x , 1.7.x and 1.8.x , but working at 1.5.x . Thanks Jacky Du

issue on Flink 1.6.2 for Table API when table schema contains nested ObjectArray

2019-07-30 Thread Jacky Du
hi, I Have column not found exception when issue running a simple FLink query against Flink Table API on Flink 1.6.2. exception log: Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Column 'data.interaction.action_type' not found in table 'mycable' When I changed Flink version