%sql 
SET spark.sql.sources.commitProtocolClass=org.apache.spark.sql.execution.datasources.SQLHadoopMapReduceCommitProtocol


spark.conf.set("mapreduce.fileoutputcommitter.marksuccessfuljobs","false")