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?????????????????????????????????????????????? ??????????????????