comments addressed

apache · Feb 7, 2015 · aa55ef4 · aa55ef4
1 parent f8f8bb1
commit aa55ef4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveWriterContainers.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveWriterContainers.scala
@@ -213,13 +213,13 @@ private[spark] class SparkHiveDynamicPartitionWriterContainer(
       .zip(row.toSeq.takeRight(dynamicPartColNames.length))
       .map { case (col, rawVal) =>
         val string = if (rawVal == null) null else String.valueOf(rawVal)
-        s"/$col=${
+        val colString = 
           if (string == null || string.isEmpty) {
             defaultPartName
           } else {
             FileUtils.escapePathName(string)
           }
-        }"
+        s"/$col=$colString"
       }.mkString
 
     def newWriter = {