如何从 FlinkSessionJob 访问节点的文件?

问题描述 投票:0回答:0

最近在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 人工制品外,节点无法访问互联网。

apache-flink flink-streaming
© www.soinside.com 2019 - 2024. All rights reserved.