[jira] [Created] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

Jacky Du
Hi, all

sorry to resend a email with correct title .

Found a fatal bug starting from Flink 1.6, which cause Flink Table API can
not correctly extract table schema .

Jira
https://issues.apache.org/jira/projects/FLINK/issues/FLINK-13603?filter=allopenissues


 there is a change on Flink-core -> RowTypeInfo -> hashcode ,  this change
make FlinkTypeFactory recognize schema with same type but different field
name as a same TypeInfo ,  this cause table schema can not be parsed
correctly .

Is any plan to fix this ? as the reverting hashcode change may fix
the problem, but I'm not sure other side affect of this change .

Thanks