如果在创建子目录时父目录不存在,我希望 HDFS 命令失败。当我使用其中任何一个时FileSystem#mkdirs
,我发现没有引发异常,而是创建了不存在的父目录:
import java.util.UUID
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path}
val conf = new Configuration()
conf.set("fs.defaultFS", s"hdfs://$host:$port")
val fileSystem = FileSystem.get(conf)
val cwd = fileSystem.getWorkingDirectory
// Guarantee non-existence by appending two UUIDs.
val dirToCreate = new Path(cwd, new Path(UUID.randomUUID.toString, UUID.randomUUID.toString))
fileSystem.mkdirs(dirToCreate)
如果没有检查存在的繁琐负担,如果父目录不存在,我如何强制 HDFS 抛出异常?