Я решил эту проблему, хотя, может быть, немного поздно:
FileSystem fs = directoryPath.getFileSystem(getConf());
FileStatus[] fileStatus = fs.listStatus(directoryPath);
for (FileStatus status : fileStatus) {
DistributedCache.addFileToClassPath(status.getPath(), conf);
}
Это то, что вы хотели сделать?