Hi todd.
-C 不会上传对应路径下的 jar,最终会被添加到集群的 classpath 中,需要运行的机器对应的路径下要有同样的Jar包才可以。
可以放在私服或者oss的服务,通过 http 的方式加载的 udf jar
-C "http://host:port/xxx.jar";

希望能帮到你。


todd <[email protected]> 于2021年4月19日周一 下午10:22写道:

> 执行指令:flink  run   \
> -m yarn-cluster \
> -C file:///xxxx/flink-demo-1.0.jar \
> xxxxx
>
> 在Client端能够构建成功jobgraph,但是在yarn上会报UDF类找不到。我看Classpath中并未上传该JAR包。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复