You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Jacky Du <ja...@gmail.com> on 2019/08/08 16:32:50 UTC
RowTypeInfo hashcode change cause Flink Table API not working
properly Starting From 1.6
Hi, all
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
Jacky Du