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

[Jacky Du <ja...@gmail.com>]

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 back to 1.5.2, it's working again. and I found
that mytable schema has an objectarray , which is a nullable value , when I
removed that array definition , the query working again in 1.6.2 .

Table query:

SELECT * FROM mycable WHERE data.interaction.action_type ='Complete'
or data.interaction.action_type ='Cancelled'

Table schema:

 |-- data: Row(attributeList: ObjectArrayTypeInfo<Row(product:
Row(status: String), value: String)>, interaction: Row(action_type:
String), tool: Row(ticket_number: String), customerAccount:
Row(billingId: String), info: Row(timestamp: BigDecimal))
 |-- entityId: String
 |-- eventType: String
 |-- eventSource: String
 |-- timestamp: String
 |-- encryption: Row(status: String)

If I remove that objectarray , which is attributeList in data field . The
query working , schema like this : Table schema:

 |-- data: Row(interaction: Row(action_type: String), tool:
Row(ticket_number: String), customerAccount: Row(billingId: String),
info: Row(timestamp: BigDecimal))
 |-- entityId: String
 |-- eventType: String
 |-- eventSource: String
 |-- timestamp: String
 |-- encryption: Row(status: String)

Or, I even changed the order of objectarray in the data field, it's working
.

I'm so confused about this issue, I tried to understand why this happened ,
tried to read the Flink source code as well , but can not find the root
cause .