用的是 Hive Catalog 吗? Hive connector 和 Hive 的版本 都是多少呢? 另外,详细堆栈贴一下。
Best regards, Yuxia ----- 原始邮件 ----- 发件人: 18579099...@163.com 收件人: "user-zh" <user-zh@flink.apache.org> 发送时间: 星期一, 2022年 5 月 09日 下午 5:46:02 主题: flink sql无法读取Hive映射的HBase表 我有一部分表的数据是存在hbase上的,平时通过hive加载外部表的方式读取hbase的数据,我想通过flink sql读取hive表的方式 读取数据(不直接使用flink 读取hbase是我使用的catalog是hive,不用再写建表语句然后再查),当我用sql-client尝试的时候报错。 读取正常的hive是可以正常读取的,但是读取hive on hbase表却报 [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.catalog.exceptions.CatalogException: Failed to get table schema from deserializer。 不知道有没有什么办法可以解决这个问题,使用spark引擎是可以读取到数据的。 18579099...@163.com