You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Eron Wright (JIRA)" <ji...@apache.org> on 2019/01/02 02:54:00 UTC

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

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)