[jira] [Created] (FLINK-11247) Fix DESCRIBE command to support catalog tables

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-11247) Fix DESCRIBE command to support catalog tables

Shang Yuanchun (Jira)
Eron Wright  created FLINK-11247:
------------------------------------

             Summary: Fix DESCRIBE command to support catalog tables
                 Key: FLINK-11247
                 URL: https://issues.apache.org/jira/browse/FLINK-11247
             Project: Flink
          Issue Type: Sub-task
            Reporter: Eron Wright


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

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

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")}}).



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)