[jira] [Created] (FLINK-13279) not able to query table registered in catalogs

[Shang Yuanchun (Jira)]

Bowen Li created FLINK-13279:
--------------------------------

             Summary: not able to query table registered in catalogs
                 Key: FLINK-13279
                 URL: https://issues.apache.org/jira/browse/FLINK-13279
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Client
    Affects Versions: 1.9.0, 1.10.0
            Reporter: Bowen Li
            Assignee: Kurt Young
             Fix For: 1.9.0, 1.10.0


When querying a simple table in catalog, SQL CLI reports "org.apache.flink.table.api.TableException: No table was registered under the name ArrayBuffer(default: select * from hivetable)."

[~ykt836] can you please help to triage this ticket to proper person?

Repro steps in SQL CLI (to set up dependencies of HiveCatalog, please refer to dev/table/catalog.md):

{code:java}
Flink SQL> show catalogs;
default_catalog
myhive

Flink SQL> use catalog myhive
> ;

Flink SQL> show databases;
default

Flink SQL> show tables;
hivetable
products
test

Flink SQL> show hivetable;
[ERROR] Unknown or invalid SQL statement.

Flink SQL> describe hivetable;
root
 |-- name: STRING
 |-- score: DOUBLE


Flink SQL> select * from hivetable;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: No table was registered under the name ArrayBuffer(default: select * from hivetable).
{code}

Exception in log:


{code:java}
2019-07-15 14:59:12,273 WARN  org.apache.flink.table.client.cli.CliClient                   - Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Invalid SQL query.
        at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQueryInternal(LocalExecutor.java:485)
        at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQuery(LocalExecutor.java:317)
        at org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:469)
        at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:291)
        at java.util.Optional.ifPresent(Optional.java:159)
        at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:200)
        at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:123)
        at org.apache.flink.table.client.SqlClient.start(SqlClient.java:105)
        at org.apache.flink.table.client.SqlClient.main(SqlClient.java:194)
Caused by: org.apache.flink.table.api.TableException: No table was registered under the name ArrayBuffer(default: select * from hivetable).
        at org.apache.flink.table.api.internal.TableEnvImpl.insertInto(TableEnvImpl.scala:529)
        at org.apache.flink.table.api.internal.TableEnvImpl.insertInto(TableEnvImpl.scala:507)
        at org.apache.flink.table.api.internal.BatchTableEnvImpl.insertInto(BatchTableEnvImpl.scala:58)
        at org.apache.flink.table.api.internal.TableImpl.insertInto(TableImpl.java:428)
        at org.apache.flink.table.api.internal.TableImpl.insertInto(TableImpl.java:416)
        at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeQueryInternal$10(LocalExecutor.java:476)
        at org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:202)
        at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQueryInternal(LocalExecutor.java:474)
        ... 8 more

{code}





--
This message was sent by Atlassian JIRA
(v7.6.14#76016)