大佬们 我部署作业到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] | 签名由网易邮箱大师定制
