现在回答这个问题可能已经很晚了，但我也遇到了这个问题，并提出了解决办法。
首先，没有像这样的支持 MultipleAvroParquetOutputFormat '内置 parquet-mr . 但为了达到类似的效果 MultipleOutputs .
对于只使用Map的工作，请按以下方式放置Map绘制器：

public class EventMapper extends Mapper<LongWritable, BytesWritable, Void, GenericRecord>{

    protected  KafkaAvroDecoder deserializer;
    protected String outputPath = "";

    // Using MultipleOutputs to write custom named files
    protected MultipleOutputs<Void, GenericRecord> mos;

    public void setup(Context context) throws IOException, InterruptedException {
        super.setup(context);
        Configuration conf = context.getConfiguration();           
        outputPath = conf.get(FileOutputFormat.OUTDIR);
        mos = new MultipleOutputs<Void, GenericRecord>(context);
    }

    public void map(LongWritable ln, BytesWritable value, Context context){

        try {
            GenericRecord record = (GenericRecord) deserializer.fromBytes(value.getBytes());
            AvroWriteSupport.setSchema(context.getConfiguration(), record.getSchema());
            Schema schema = record.getSchema();
            String mergeEventsPath = outputPath + "/" + schema.getName(); // Adding '/' will do no harm 
            mos.write( (Void) null, record, mergeEventsPath);

        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void cleanup(Context context) throws IOException, InterruptedException {
        mos.close();
    }

}

这将创建一个新的 RecordWriter 为每个模式创建一个新的parquet文件，并附加模式名称，例如schema1-r-0000.parquet。
这还将根据驱动程序中设置的模式创建默认的part-r-0000x.parquet文件。要避免这种情况，请使用 LazyOutputFormat 比如：

LazyOutputFormat.setOutputFormatClass(job, AvroParquetOutputFormat.class);

希望这有帮助。