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)