如何将apache-kuflintes文件上传到bernfrink中


0

我在kubernetesv1.15.2中使用apacheflinkv1.10.0,现在我可以成功地运行flink job并保存历史任务。现在问题是我上传的jar存储在apache flink的pod中。因为豆荚主机的存储空间只有很小的40GB,已经用了30GB+。现在我希望上传的jar可以存储在NFS中。我已经在当前taskmanager的pod的/opt/data目录中挂载了PV,但是文件没有存储在NFS中。

我应该编写什么配置来将上传的jar文件存储在NFS中并释放主机空间?这是当前的I am配置:

web.upload.dir: /opt/flink/data/jars

我试过用这个,但失败了:

web.upload.dir: file:///opt/flink/data/jars

但像这样的 checkpoints存储有效:

env.setStateBackend(new FsStateBackend("file:///opt/flink/data"));

那我该怎么办?谢谢。这是当前存储的文件:

1 答案


0

我想你的目录名有问题。

您已经在:/opt/data创建了一个PV。但是您的配置将dir路径定义为:/opt/flink/data/jars。将配置路径更改为/opt/data/jars可能会起作用。

N、 B.运行Flink的用户应该具有对文件夹的写访问权限。

以下是您可以执行的调试操作:

    您可以检查/opt/flink/data/jars目录。或者,
Using directory <dir_name> for web frontend JAR file uploads.

Created directory <dir_name> for web frontend JAR file uploads.

Jar upload directory <dir_name> cannot be created or is not writable.

我来回答

写文章

提问题

面试题