Mkdirs 无法在 Kubernetes 中创建文件 - Apache Flink答案

【问题标题】：Mkdirs failed to create file in Kubernetes - Apache FlinkMkdirs 无法在 Kubernetes 中创建文件 - Apache Flink
【发布时间】：2022-08-23 01:54:05
【问题描述】：

我在 Kubernetes 中使用 Flink Operator 以 Appication 模式部署 Apache Flink 集群，但存在权限问题。我将 Filestore 实例安装为 ReadWriteMany 卷。当我 \"kubectl exec\" 到 taskmanager pod 时，我可以访问挂载的卷 \"/flink-data\"。我也可以在里面创建目录。但是，每当检查点被触发时，我仍然会收到以下错误：

Caused by: java.io.IOException: Mkdirs failed to create file:/flink-data/checkpoints/f6dc4b42c99ac5d25f4be4771a9c6889/chk-1
    at org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:262) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at org.apache.flink.core.fs.SafetyNetWrapperFileSystem.create(SafetyNetWrapperFileSystem.java:130) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at org.apache.flink.core.fs.EntropyInjector.createEntropyAware(EntropyInjector.java:61) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.createStream(FsCheckpointStreamFactory.java:401) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.flushToFile(FsCheckpointStreamFactory.java:258) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.write(FsCheckpointStreamFactory.java:234) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
    at java.io.DataOutputStream.write(DataOutputStream.java:107) ~[?:1.8.0_342]

标签： apache-flink kubernetes-pod

【解决方案1】：

我能够弄清楚并解决许可问题。在检查了引导我进入该文件的 Apache Flink docker 映像后 - https://github.com/apache/flink-docker/blob/master/1.13/scala_2.12-java8-debian/docker-entrypoint.sh ...我以 root 身份运行该映像，而不是 flink 的 uid 和 gid 的“9999”。我创建了一个 initContainer 来将挂载的 pvc 的所有权从 root 更改为 flink。

【讨论】：