[FLINK-22884] Select view columns fail when store metadata with hive

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.1
• Fix Version/s: 1.14.0, 1.13.2
• Component/s: Connectors / Hive
• Labels: pull-request-available stale-assigned
• Assignee: Rui Li
• Reporter: ELLEX_SHEN
• Created: 05/Jun/21 06:56
• Updated: 14/Jul/21 08:16
• Resolved: 06/Jul/21 04:01

Description

I am use hive for filnk metadata, so select view table will mismatch to hive table after create view, I founded is a bug in HiveCatalog.classs, all view table is default mark to hive table unexpected.

after store in hive metadata, view table without "is_generic" or "connector" properties.

bug is here:

@VisibleForTesting
public Table getHiveTable(ObjectPath tablePath) throws TableNotExistException {
try {
Table table = this.client.getTable(tablePath.getDatabaseName(), tablePath.getObjectName());
boolean isHiveTable;
if (table.getParameters().containsKey("is_generic"))

{ isHiveTable = !Boolean.parseBoolean((String)table.getParameters().remove("is_generic")); }

else

{ isHiveTable = !table.getParameters().containsKey("flink." + FactoryUtil.CONNECTOR.key()) && !table.getParameters().containsKey("flink.connector.type"); }

if (isHiveTable)

{ table.getParameters().put(FactoryUtil.CONNECTOR.key(), "hive"); }

return table;
} catch (NoSuchObjectException var4)

{ throw new TableNotExistException(this.getName(), tablePath); }

catch (TException var5)

{ throw new CatalogException(String.format("Failed to get table %s from Hive metastore", tablePath.getFullName()), var5); }

}

Issue Links

• links to: GitHub Pull Request #16149