[FLINK-12848] Method equals() in RowTypeInfo should consider fieldsNames

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.2
• Fix Version/s: 1.8.3, 1.9.2, 1.10.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Aloys Zhang
• Reporter: Aloys Zhang
• Created: 14/Jun/19 08:06
• Updated: 18/Oct/19 16:08
• Resolved: 18/Oct/19 16:08

Description

Since the `RowTypeInfo#equals()` does not consider the fieldNames , when process data with RowTypeInfo type there may comes an error of the field name.  

String [] fields = new String []{"first", "second"};
TypeInformation<?>[] types = new TypeInformation[]{
Types.ROW_NAMED(new String[]{"first001"}, Types.INT),
Types.ROW_NAMED(new String[]{"second002"}, Types.INT) }; StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment env = StreamTableEnvironment.getTableEnvironment(execEnv);
SimpleProcessionTimeSource streamTableSource = new SimpleProcessionTimeSource(fields, types);
env.registerTableSource("testSource", streamTableSource);
Table sourceTable = env.scan("testSource");
System.out.println("Source table schema : ");
sourceTable.printSchema();

The table shcema will be 

Source table schema : 
root 
|-- first: Row(first001: Integer) 
|-- second: Row(first001: Integer) 
|-- timestamp: TimeIndicatorTypeInfo(proctime)

the second field has the same name with the first field.

So, we should consider the fieldnames in RowTypeInfo#equals()

 

 

 

 

Issue Links

• links to: GitHub Pull Request #8737
• links to: GitHub Pull Request #9930