我有这个脚本，它在本地机器上工作。

public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {

    Job job = Job.getInstance(new Configuration(), "ToParquet");

    job.setJarByClass(ToParquet.class);

    job.setMapperClass(BasicsMapper.class);
    job.setMapperClass(RatingsMapper.class);

    job.setReducerClass(MyReducer.class);

    job.setMapOutputKeyClass(Text.class);
    job.setMapOutputValueClass(Text.class);

    MultipleInputs.addInputPath(job, new Path("hdfs:///title.basics.tsv"), TextInputFormat.class, BasicsMapper.class);
    MultipleInputs.addInputPath(job, new Path("hdfs:///title.ratings.tsv"), TextInputFormat.class, RatingsMapper.class);

    job.setOutputKeyClass(Void.class);
    job.setOutputValueClass(GenericRecord.class);

    job.setOutputFormatClass(AvroParquetOutputFormat.class);
    AvroParquetOutputFormat.setSchema(job, getSchema());
    FileOutputFormat.setOutputPath(job, new Path("hdfs:///to_parquet_output"));

    job.waitForCompletion(true);

但是，当我尝试在hfds环境中运行它时，会显示以下错误消息。

我不知道发生了什么。如果有人能帮我，我很感激。