最近在linux系统安装了Flink kubernetes operator。我为 FlinkDeployment 和 FlinkSessionJob 创建了 yaml 文件。 FlinkDeployment 创建成功,但由于无法访问 jarURI 路径,无法创建 FlinkSessionJob。 这是 FlinkDeployment 和 FlinkSessionJob 文件。
FlinkDeployement-abcd.yaml:
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
name: fbp-abcd-deployment
namespace: dev
....
....
FlinkSessionJob-abcd.yaml
apiVersion: flink.apache.org/v1beta1
kind: FlinkSessionJob
metadata:
name: fbp-abcd-job
spec:
deploymentName: fbp-abcd-deployment
job:
jarURI: file:/home/abcd/fbp-acc-lc.jar # which are present in Node
parallelism: 2
upgradeMode: savepoint
entryClass: com.abcd.accountmgmt.FlinkMain
allowNonRestoredState: true
这里是 FlinkSessionJob 对象 fb-abcd-job 的报错
状态: 错误:{“type”:“org.apache.flink.kubernetes.operator.exception.ReconciliationException”,“message”:“java.io.FileNotFoundException:/home/abcd/fbp-acc-lc.jar(没有这样的文件或目录)”,“throwableList”:[{“type”:“java.io.FileNotFoundException”,“message”:“/home/abcd/fbp-acc-lc.jar(没有这样的文件或目录)”}] }
请帮助我如何从 FlinkSessionJob 访问节点的文件系统。
我试图从 FlinkSessionJob 访问节点中的文件。我期待 flinksessionjob 访问节点的文件系统。
除了需要用户凭据的组织的 jfrog 人工制品外,节点无法访问互联网。