大佬们
我部署作业到k8s集群,有多个作业共享一个外部的jar的情况。外部的jar的通过共享存储,每个JM、TM都能访问。
我使用-C指定依赖的classpath。但是依然找不到对应的class。问题可能出在哪里呢??
提交命令如下:


bin/flink run-application -t kubernetes-application 
-Dkubernetes.cluster-id=demo 
-Dkubernetes.container.image=devhub.baymax.oppo.local/flink-browser-cluster/flink:1.13.2-scala_2.11-java8-centos-v1.0.0
 -Dkubernetes.container.image.pull-policy=Always 
-Dkubernetes.rest-service.exposed.type=NodePort -C 
file:///home/service/var/chubaofs/flink/user/usrlib/demo/httpclient-4.5.2.jar 
-c com.martin.RandomDemo -p 2 
local:///opt/flink/user/jars/flink-demo-1.0-without-http-SNAPSHOT.jar





部署截图:


错误截图:


| |
johnjlong
|
|
[email protected]
|
签名由网易邮箱大师定制

回复