Flink1.13.1??????Catalog????????

[hoose]

Flink1.13.1??Catalog??????????????????????????????????????
??
JdbcCatalogFactory implements CatalogFactory????
??????????????????????
public Map<String, String&gt; requiredContext()
&nbsp;public List<String&gt; supportedProperties()
&nbsp;public Catalog createCatalog(String name, Map<String, String&gt; 
properties)



??????????????
&nbsp; public Set<ConfigOption<?&gt;&gt; requiredOptions()
&nbsp; public Set<ConfigOption<?&gt;&gt; optionalOptions()
&nbsp; 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
??????????????????
&nbsp; &nbsp; &nbsp;private static Map<String, String&gt; 
normalizeContext(TableFactory factory) {
&nbsp; &nbsp; &nbsp; &nbsp; Map<String, String&gt; requiredContext = 
factory.requiredContext();
&nbsp; &nbsp; &nbsp; &nbsp; if (requiredContext == null) {
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; throw new TableException(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
String.format(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; "Required context of factory '%s' must not be null.",
&nbsp; &nbsp; &nbsp; &nbsp;??&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; &nbsp;factory.getClass().getName()));

????????????requiredContext == 
null????????????????requiredContext()????????????????????api??????????????????????????????????????????????


??????????????????