退订
Hi.
新版的 CatalogFactory 实现了 Factory，这意味着当前的所有的 connector、format 以及 Catalog
都实现了相同的接口，保持了统一性。而保持原来的方法，更多是为了暂时的兼容性( 我的理解 )： 如果 某个Catalog
从低版本迁移到高版本只需要添加一些新的接口方法，而不需要删除之前的逻辑。之后的版本可能会删除这些已经被deprecated 方法。
Best,
Shengkai.
hoose 于2021年7月15日周四 下午6:13写道：
> Flink1.13.1在Catalog方面修改比较大，特别是一些方法的实现上
> 如
>
能不能把依赖和相关代码贴一下
| |
Page
|
|
lj879933...@163.com
|
签名由网易邮箱大师定制
在2021年7月13日 18:36，沉黙ｄē羔羊<736036...@qq.com.INVALID> 写道：
大家好，请教下，用了flink hudi 写入数据报错，如下：
Caused by: org.apache.flink.util.FlinkException: Error from OperatorCoordinator
... 41 more
Caused by: java.lang.AbstractMethodError: Method
Flink1.13.1??Catalog??
??
JdbcCatalogFactory implements CatalogFactory
??
public Map
