IDEA运行flikcdc的相关问题

按照官方文档跑Demo一直报错，记录一些错误

错误1

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/java/typeutils/ResultTypeQueryable

解决1：去掉pom文件中的 <scope>provided</scope> 代码

解决2：配置modify run configuraton->modify options->add dependencies with “provided” scope to classpath

错误2：

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/connector/base/source/reader/RecordEmitter

添加flink-connector-base 依赖，不知道为什么官方没写这个依赖。

flink-connector-kafka、flink-connector-mysql-cdc，通常依赖于 flink-connector-base，并实现这些通用接口来满足特定存储系统的需要。

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-base</artifactId>
        <version>${flink.version}</version>
    </dependency>

​

1. https://github.com/ververica/flink-cdc-connectors/issues/2802 ↩