Re: flink1.11版本 -C 指令并未上传udf jar包

Tue, 20 Apr 2021 19:08:14 -0700 

-C,--classpath <url>                 Adds a URL to each user code
                                          classloader  on all nodes in the
                                          cluster. The paths must specify a
                                          protocol (e.g. file://) and be
                                          accessible on all nodes (e.g. by means
                                          of a NFS share). You can use this
                                          option multiple times for specifying
                                          more than one URL. The protocol must
                                          be supported by the {@link
                                          java.net.URLClassLoader}.

-C指定依赖jar包需要放在URLClassLoader能够访问到的位置。



在 2021/4/19 下午10:22，“todd”<[email protected]> 写入:

    执行指令：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/

回复