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
