Junling created FLINK-14085:
-------------------------------
Summary: schema changes after using "create view" command via flink-table-sql-client
Key: FLINK-14085
URL:
https://issues.apache.org/jira/browse/FLINK-14085 Project: Flink
Issue Type: Bug
Components: Table SQL / Client, Table SQL / Planner
Affects Versions: 1.9.0, 1.8.0, 1.7.2
Environment: Centos 7.0 / JAVA 1.8
Reporter: Junling
Assume there are two tables in the running environment of the flink sql client.
One is abc12, the schema is ROW<taskId VARCHAR, sourceId VARCHAR,data ROW<id VARCHR,value1 VARCHAR>>
The other is abc13, the schema is ROW<taskId VARCHAR, sourceId VARCHAR,data ROW<id VARCHR,value2 VARCHAR>>
If we execute the "create view" command such as " create view myview as select data from abc12", then the bug will happen. The schema of the table abc13 will change as ROW<taskId VARCHAR, sourceId VARCHAR,data ROW<id VARCHR,value1 VARCHAR>>
We found that the schema of the second table will be change after running "create view" command on the first table if these two tables have the row type field with the same structure. Here the same structure means that the field type of the row field is same, and the field name can be different. e.g. data ROW<a VARCHAR,b VARCHAR> and data1 ROW<c VARCHAR,d VARCHAR> has the same structure. As the affect of the row type field with the same structure, it will replace the orignal schema of the row type field in the second table by the schema of the row type field in the first table.
This bug exits in the flink 1.7, 1.8 and 1.9. In the 1.7 version, we can use the "describe" command to see the changed schema. In the 1.9 version, since the catalogManager is introduced, it looks good when using the "describe" command. However, when using "select" command to select the filed name in the row type filed, it will rise up an exception that says the column not exists in the table, which means the schema of the table still changes.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
Locked
