[FLINK-22196] FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.2
• Fix Version/s: 1.13.0
• Component/s: Table SQL / Planner
• Assignee: Lsw_aka_laplace
• Reporter: Lsw_aka_laplace
• Created: 11/Apr/21 06:13
• Updated: 13/Apr/21 09:00
• Resolved: 13/Apr/21 09:00

Description

Well since we have supported project push-down, some primary-key in original schema may not exist no longer more, so the non-existed column shall be filtered out.

 

Current code:

val columns = relOptTable.getRowType.getFieldNames
val columnIndices = schema.getPrimaryKey.get().getColumns map { c =>
  columns.indexOf(c)
}

May be supposed to correct to:

val columns = relOptTable.getRowType.getFieldNames
val columnIndices = schema
  .getPrimaryKey
  .get()
  .getColumns
  .map(columns.indexOf)
  .filterNot(_ == -1) // filter out the non-exist column

 

Issue Links

• is fixed by: FLINK-22157 Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException