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)
