Spark 2.0 deprecates 'DirectParquetOutputCommitter', how to live without it? Spark 2.0 deprecates 'DirectParquetOutputCommitter', how to live without it? hadoop hadoop

Spark 2.0 deprecates 'DirectParquetOutputCommitter', how to live without it?


You can use: sparkContext.hadoopConfiguration.set("mapreduce.fileoutputcommitter.algorithm.version", "2")

since you are on EMR just use s3 (no need for s3a)

We are using Spark 2.0 and writing Parquet to S3 pretty fast (about as fast as HDFS)

if you want to read more check out this jira ticket SPARK-10063