[FLINK-11247] Fix DESCRIBE command to support catalog tables

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Component/s: Connectors / Hive, Table SQL / Client
• Labels: pull-request-available
• Assignee: vinoyang
• Reporter: Eron Wright
• Created: 02/Jan/19 02:53
• Updated: 19/May/20 09:23
• Resolved: 19/May/20 09:23

Description

When the DESCRIBE command is applied to a catalog table, it fails with an error:

Flink SQL> DESCRIBE nyc.TaxiRides;                                                                                                                                                
[ERROR] Could not execute SQL statement. Reason:                                                                                                                                  
org.apache.flink.table.api.TableException: Table 'nyc.TaxiRides' was not found.

The reason appears to be that LocalExecutor calls TableEnvironment::scan with the fully-qualified table name as a parameter (e.g. scan("nyc.TaxiRides")) rather than with an array of components (e.g. scan("nyc", "TaxiRides")).

Issue Links

• links to: GitHub Pull Request #8250