do a little modify

baishuo · liancheng · commit 66e33fcbf300 · 2014-09-17T01:24:12.000-07:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/SparkHadoopWriter.scala b/sql/hive/src/main/scala/org/apache/spark/SparkHadoopWriter.scala
@@ -117,7 +117,7 @@ private[hive] class SparkHiveHadoopWriter(
       conf.value.getOutputValueClass.asInstanceOf[Class[Writable]],
       fileSinkConf,
       path,
-      null)
+      Reporter.NULL)
   }
 
   def write(value: Writable) {
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
@@ -342,7 +342,7 @@ case class InsertIntoHiveTable(
       val inheritTableSpecs = true
       // TODO: Correctly set isSkewedStoreAsSubdir.
       val isSkewedStoreAsSubdir = false
-      if (dynamicPartNum>0) {
+      if (dynamicPartNum > 0) {
         db.loadDynamicPartitions(
           outputPath,
           qualifiedTableName,

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ private[hive] class SparkHiveHadoopWriter(`
`117`	`117`	`conf.value.getOutputValueClass.asInstanceOf[Class[Writable]],`
`118`	`118`	`fileSinkConf,`
`119`	`119`	`path,`
`120`		`- null)`
	`120`	`+ Reporter.NULL)`
`121`	`121`	`}`
`122`	`122`
`123`	`123`	`def write(value: Writable) {`