我的 var/log/hadoop-hdfs/hdfs-audit.log 位于本地namenode上，由 head /var/log/hadoop-hdfs/hdfs-audit.log . 我的数据文件由 hdfs dfs -ls / 而审计文件可以用光盘刻录。现在我可以用java访问我的hdfs文件，但每次我尝试 fs.getLocal(conf) 哪里 conf 由设置 conf.set(FileSystem.FS_DEFAULT_NAME_KEY, namenode) ，我在计算机上获取本地文件，而不是namenode上的本地文件。
下面的代码用于获取数据下的所有文件和目录。

public class HdfsAuditLogParser {
    private final String cluster;
    private final FileSystem fs;

    public HdfsAuditLogParser(String cluster, String namenode) throws IOException {
        this.cluster = cluster;
        Configuration conf = new Configuration();
        conf.set(FileSystem.FS_DEFAULT_NAME_KEY, namenode);
        this.fs = FileSystem.get(conf);
    }

    public String parse() throws IOException {
        for (FileStatus f : fs.listStatus(new Path("/data/"))){
            System.out.println(f.getPath().toString());
        }
        return "output";
    }
}

但是如果我把/data/改成/var/log/，它就不起作用了，我甚至尝试过切换 this.fs = FileSystem.getLocal(conf); 但这不起作用，它只给我计算机中var/log/下的文件，而不是namenode中的文件。
简而言之，我想通过java访问hdfs-audit.log文件，就像访问hdfs中的hdfs数据库和表以及其他文件一样。有什么办法吗。