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 longfeng Xu <xulongfeng2...@gmail.com> 于2023年8月2日周三 08:26写道： > 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: > > java.lang.NoSuchMethodError: 'org.apache.flink.table.catalog.CatalogTable > org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable() > > Tried many ways but failed( shaded package to fat jar like demo in > website. ) > > Thanks for your help >
