我有一部分表的数据是存在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

回复