fix minor error

jiangxb1987 · jiangxb1987 · commit 80884b7de357 · 2017-06-28T11:14:42.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriter.scala b/core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriter.scala
@@ -383,6 +383,8 @@ class HadoopMapReduceWriteConfigUtil[K, V: ClassTag](conf: SerializableConfigura
   // --------------------------------------------------------------------------
 
   override def assertConf(jobContext: NewJobContext, conf: SparkConf): Unit = {
-    getOutputFormat().checkOutputSpecs(jobContext)
+    if (SparkHadoopWriterUtils.isOutputSpecValidationEnabled(conf)) {
+      getOutputFormat().checkOutputSpecs(jobContext)
+    }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -383,6 +383,8 @@ class HadoopMapReduceWriteConfigUtil[K, V: ClassTag](conf: SerializableConfigura`
`383`	`383`	`// --------------------------------------------------------------------------`
`384`	`384`
`385`	`385`	`override def assertConf(jobContext: NewJobContext, conf: SparkConf): Unit = {`
`386`		`- getOutputFormat().checkOutputSpecs(jobContext)`
	`386`	`+ if (SparkHadoopWriterUtils.isOutputSpecValidationEnabled(conf)) {`
	`387`	`+ getOutputFormat().checkOutputSpecs(jobContext)`
	`388`	`+ }`
`387`	`389`	`}`
`388`	`390`	`}`