Hi Robin Zhang, 其实在只要不是在根目录下创建文件夹，只要在我指定的目录下创建即可，我其实是有权限的，Hadoop管理员给我分配了一个目录，我想把目录设置到分配的目录，但是一直报这个错，想问一下除了创建job信息，Flink还有什么机制会去hdfs上创建文件或文件夹的？ 祝好！
在 2020年9月29日 17:15，Robin Zhang<vincent2015q...@outlook.com> 写道： Hi jester_jim， 配置文件中指定的checkpoints（以后简称ckp）的目录只是一个父目录，flink在首次触发每个job的ckp时会在这个父目录下新建多级文件夹，命名为指定的job名字/job id.所以，并不是新建父目录就可以，依然会存在权限问题 。 祝好，Robin Zhang Flink中文社区的各位大佬你们好： 本人是小白，由于对Flink不太了解，想学，然后搭了个Flink standalone（1.11.2 jdk1.8）集群，集群本身运行没有什么问题，作业运行也没什么问题。但是最近有用到状态后端，在配置hdfs的时候遇到了一个无法理解的问题，我在issues也没找到解决方法。问题大概是，我在Flink配置文件配置了HDFS状态后端，但是呢Hadoop（CDH2.5.0）是生产系统的集群，有kerberos认证，目录权限不全开放。Flink的配置信息如下： state.backend: filesystem # Directory for checkpoints filesystem, when using any of the default bundled # state backends. # state.checkpoints.dir: hdfs://namenode58:9000/NS3/user/jester/flink/flink-checkpoints # Default target directory for savepoints, optional. # state.savepoints.dir: hdfs://namenode58:9000/NS3/user/jester/flink/flink-checkpoints 除此之外还有kerberos认证配置，但是都没有什么问题，如下所示，当注释掉上面三行配置过后，作业正常运行： 2020-09-29 11:27:20,430 INFO org.apache.hadoop.security.UserGroupInformation [] - Login successful for user jester/principle using keytab file /kafka/flink/flink-1.11.2/conf/jester.keytab Job has been submitted with JobID 41c01241338f1c7112d48f277701d9c3 但是如果不注释，当我提交作业就会抛出： （本部分放在异常信息前面： 异常里面说Flink要去/目录创建文件但是没有write权限，但是这个权限肯定是不会给的。但是我明明在Flink配置中我已经指定了目录，我不能理解为什么还会在/下创建什么？除此之外，Hadoop的配置信息我是直接把Hadoop集群的目录拷贝过来了，在启动脚本中指定了HADDOP_CONF_DIR，（本人觉得其实这样好像是不太妥当的，因为Hadoop的hdfs-site.xml和core-site.xml里面有很多只能在Hadoop集群的机器上使用的配置，不知道是不是应该删除无用的配置，还有增加必要的配置，希望能有参考文档）还有Hadoop的jar包我直接`$HADDOP_HOME/bin/hadoop classpath` 另外还有个问题，就是Hadoop配置了HA，我怎么给checkpoint配置多个namenode？ ） 2020-09-29 11:21:20,446 INFO org.apache.hadoop.security.UserGroupInformation [] - Login successful for user jester/principle using keytab file /kafka/flink/flink-1.11.2/conf/unicom_jiangt37.keytab -- Sent from: http://apache-flink.147419.n8.nabble.com/
