这个问题我之前部署Flink流作业到YARN集群时也踩过坑，核心原因就是运行时TaskManager找不到JedisCluster类，属于依赖未正确分发的典型问题，给你几个实用的解决方向：

1. 打包时构建包含所有依赖的Fat Jar #

这是最稳妥的方式，把作业代码和所有第三方依赖（比如Jedis）打包到同一个JAR里，确保TaskManager能直接找到类文件。

如果你用Maven，可以用maven-shade-plugin来配置，示例如下：

<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-shade-plugin</artifactId>
            <version>3.4.1</version>
            <executions>
                <execution>
                    <phase>package</phase>
                    <goals>
                        <goal>shade</goal>
                    </goals>
                    <configuration>
                        <!-- 排除Flink自带的依赖，避免冲突 -->
                        <excludeGroupIds>org.apache.flink</excludeGroupIds>
                        <transformers>
                            <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                                <!-- 指定你的作业主类 -->
                                <mainClass>com.yourcompany.YourFlinkJob</mainClass>
                            </transformer>
                        </transformers>
                    </configuration>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>

打包后可以用jar tf your-job-fat.jar | grep redis/clients/jedis/JedisCluster验证类是否存在。

2. 通过Flink CLI提交时指定依赖JAR #

如果不想打包成Fat Jar，可以在提交作业时通过--jars参数指定Jedis的依赖包，Flink会自动把这些JAR分发到所有YARN节点的TaskManager上：

flink run -m yarn-cluster --jars /local/path/to/jedis-x.x.x.jar com.yourcompany.YourFlinkJob

如果有多个依赖包，用逗号分隔路径即可。

3. 将依赖包放到Flink集群的lib目录（临时应急用） #

把Jedis的JAR包复制到所有Flink节点的$FLINK_HOME/lib目录下，然后重启Flink集群。这种方式会让所有Flink作业都加载这个依赖，容易引发版本冲突，只适合临时测试场景，不推荐生产环境使用。

额外排查点 #

• 确认你的项目依赖中已经正确引入了Jedis，并且scope是compile（不要用provided，除非集群lib目录已经有对应版本）；
• 检查提交的JAR包是否正确，避免误提交了未包含依赖的瘦JAR。

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