目前还不能直接 把HiveDynamicTableFactory直接作为一个connector使用。
把 HiveDynamicTableFactory 改造一下,
factoryIdentifier 不能再抛出  UnsupportedOperationException("Hive factory is only 
work for catalog.") 异常了,
改造工作量不大。

Best regards,
Yuxia

----- 原始邮件 -----
发件人: "yanggang_it_job" <yanggang_it_...@163.com>
收件人: "user-zh" <user-zh@flink.apache.org>
发送时间: 星期一, 2022年 9 月 19日 下午 5:04:00
主题: Flink-1.15 HiveDynamicTableFactory 取Catalog使用

当前使用HiveDynamicTableFactory需要先声明HiveCatalog才可以使用。
请问能否把HiveDynamicTableFactory直接作为一个connector使用,或者说需要怎么调整才可以直接使用?

回复