issue on Flink 1.6.2 for Table API when table schema contains nested ObjectArray
I Have column not found exception when issue running a simple FLink query against Flink Table API on Flink 1.6.2.
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 .
SELECT * FROM mycable WHERE data.interaction.action_type ='Complete' or data.interaction.action_type ='Cancelled'