我想使用FlinkSink写hdfs使用snappy压缩代码是这样写（参考下列）提交后报错是为什么？[阿里云实时计算 Flink版] 暂停朗读为您朗读

我想使用FlinkSink写hdfs。使用snappy压缩。 代码是这样写的： CompressWriterFactory writer = CompressWriters.forExtractor(new DefaultExtractor()) .withHadoopCompression(codec, conf);

    FileSink sink = FileSink
            .forBulkFormat(new Path(outputPath), writer)

提交到yarn上后报错：请问是什原因？