目前还不能直接 把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使用,或者说需要怎么调整才可以直接使用?