目前还不能直接 把HiveDynamicTableFactory直接作为一个connector使用。
把 HiveDynamicTableFactory 改造一下,
factoryIdentifier 不能再抛出 UnsupportedOperationException("Hive factory is only
work for catalog.") 异常了,
改造工作量不大。
Best regards,
Yuxia
----- 原始邮件 -----
发件人: "yanggang_it_job" <[email protected]>
收件人: "user-zh" <[email protected]>
发送时间: 星期一, 2022年 9 月 19日 下午 5:04:00
主题: Flink-1.15 HiveDynamicTableFactory 取Catalog使用
当前使用HiveDynamicTableFactory需要先声明HiveCatalog才可以使用。
请问能否把HiveDynamicTableFactory直接作为一个connector使用,或者说需要怎么调整才可以直接使用?