Flink1.13.1自定义Catalog问题出错怎么解决？

Flink1.13.1在Catalog方面修改比较大，特别是一些方法的实现上

如

JdbcCatalogFactory implements CatalogFactory中：

核心三个方法全部过期：

public Map<String, String> requiredContext()

 public List<String> supportedProperties()

 public Catalog createCatalog(String name, Map<String, String> properties)

新的替换方法：

  public Set<ConfigOption<?>> requiredOptions()

  public Set<ConfigOption<?>> optionalOptions()

  public Catalog createCatalog(Context context)

用新的方法打包之后运行：

Exception in thread "main" org.apache.flink.table.api.TableException: Required context of factory 'com.apache.flink.catalog.factory.MysqlCatalogFactory' must not be null

跟踪代码进去发现，

     private static Map<String, String> normalizeContext(TableFactory factory) {

        Map<String, String> requiredContext = factory.requiredContext();

        if (requiredContext == null) {

            throw new TableException(

                    String.format(

                            "Required context of factory '%s' must not be null.",

       ｝                     factory.getClass().getName()));

看错误是因为requiredContext == null了，其实就是上面requiredContext()没有实现，不明白新版api都把这个方法过期了，为啥在后面还要调用判断他？*来自志愿者整理的flink邮件归档