From 8ad173cd41e2abb93df681383cf15aa59e3484c5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?baishuo=28=E7=99=BD=E7=A1=95=29?= <vc_java@hotmail.com>
Date: Mon, 18 Aug 2014 15:44:07 +0800
Subject: [PATCH] Update InsertIntoHiveTable.scala

---
 .../spark/sql/hive/execution/InsertIntoHiveTable.scala       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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
index 8f327d1887a23..4df9fad385b42 100644
--- 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
@@ -270,7 +270,7 @@ case class InsertIntoHiveTable(
       }
     }
 
-    if (dynamicPartNum>0) {
+    if (dynamicPartNum > 0) {
       if (outputClass == null) {
         throw new SparkException("Output value class not set")
       }
@@ -343,7 +343,6 @@ case class InsertIntoHiveTable(
         sc.hiveconf.getBoolean("hive.exec.compress.output", false))
     }
 
-    // TODO: Handle dynamic partitioning.
     val outputPath = FileOutputFormat.getOutputPath(jobConf)
     // Have to construct the format of dbname.tablename.
     val qualifiedTableName = s"${table.databaseName}.${table.tableName}"
@@ -359,7 +358,7 @@ case class InsertIntoHiveTable(
       val inheritTableSpecs = true
       // TODO: Correctly set isSkewedStoreAsSubdir.
       val isSkewedStoreAsSubdir = false
-      if (dynamicPartNum>0) {
+      if (dynamicPartNum > 0) {
         db.loadDynamicPartitions(
           outputPath,
           qualifiedTableName,