Flink提交JAR运行时报ClassNotFoundException但类存在如何解决？

该异常核心是Flink运行时反序列化作业拓扑配置时，无法加载业务自定义类com.rdata.watcher.streaming.Selector，即使JAR包中存在该类，也可按以下优先级排查：

1. 打包正确性验证 #

• 执行命令jar tf 提交的任务包.jar | grep "com/rdata/watcher/streaming/Selector.class"，确认输出的类路径和异常中的全限定类名完全一致，无大小写、包名字符拼写错误。
• 确认你提交的是包含全部业务代码和依赖的Fat JAR，若使用maven打包，需正确配置maven-shade-plugin或maven-assembly-plugin，未将业务代码包通过排除规则过滤，也未给业务代码模块设置<scope>provided</scope>。

2. 类加载顺序配置校验 #

• Flink默认部分版本采用父类加载器优先策略，若集群公共lib目录存在同包名冲突类，会优先加载集群侧的类导致找不到用户JAR中的类。提交任务时添加参数-Dclassloader.resolve-order=child-first，强制优先加载用户JAR中的类验证问题。

3. 序列化规则检查 #

• 确认Selector类实现了java.io.Serializable接口，类中不可序列化的成员变量需添加transient关键字修饰，或自定义实现序列化/反序列化逻辑。
• 确认本地编译JAR使用的JDK版本小于等于Flink集群运行的JDK版本，高版本JDK编译的类无法在低版本JDK环境加载。

4. 提交配置验证 #

• 确认提交命令中指定的JAR路径正确，未误提交旧版本无该类的JAR包。可清空目标目录后重新打包提交测试。
• 若采用Session模式提交任务，可重启Session集群后重试，避免旧作业的类加载器缓存导致异常。

5. 依赖冲突排查 #

• 若以上步骤均无问题，可执行mvn dependency:tree检查工程依赖，是否存在多个版本的同包名类冲突，导致打包时类被覆盖。

内容的提问来源于stack exchange，提问作者guru