You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@zeppelin.apache.org by "Donald Yand (Jira)" <ji...@apache.org> on 2021/01/09 08:21:00 UTC

[jira] [Created] (ZEPPELIN-5193) Describe table using full table name in FlinkSQL can not work

Donald Yand created ZEPPELIN-5193:
-------------------------------------

             Summary: Describe table using full table name in FlinkSQL can not work
                 Key: ZEPPELIN-5193
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-5193
             Project: Zeppelin
          Issue Type: Bug
          Components: flink
    Affects Versions: 0.9.0
            Reporter: Donald Yand
         Attachments: image-2021-01-09-16-18-37-418.png, image-2021-01-09-16-19-58-087.png

If I use describe command in Flink Sql with a full table name like hive.flink.some_table, it will throw a exception;

!image-2021-01-09-16-18-37-418.png|width=426,height=165!

but if I use "

use catalog hive;

use flink;

describe some_table;

"

it works;

I check the code,  the "callDescribe" function in "FlinkSqlInterrpeter.java" use "tbenv.scan" to get table schema;

the scan function need a string array when use a full table, but 0.9.0 version call it with a string. 

!image-2021-01-09-16-19-58-087.png|width=724,height=163!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)