Hi, longfeng.
I think you should rebuild your connector according to the new API. The
return type of the method `DynamicTableFactory$Context.getCatalogTable()`
is already changed from `CatalogTable` to `ResolvedCatalogTable`[].
Best,
Hang
[1] https://issues.apache.org/jira/browse/FLINK-21913
Flink 1.13.3
Custom connector Using flink Kafka connector code and little refactoring;
And Custom connector can be load in flink 1.12 when using
StreamTableEnvironment.
Now flink upgrade to 1.13.3, custom connector dependencies also upgraded to
1.13.3
But failed to load:
