Update SparkSqlParser.scala

adrian-wang · web-flow · commit 0edfed48a1e6 · 2016-07-18T15:46:56.000+08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala
@@ -1340,7 +1340,7 @@ class SparkSqlAstBuilder(conf: SQLConf) extends AstBuilder {
         val name = conf.getConfString("hive.script.serde",
           "org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe")
         val props = Seq("field.delim" -> "\t")
-        val recordHandler = defaultRecordHandler(configKey)
+        val recordHandler = Try(conf.getConfString(configKey, configValue)).toOption
         (Nil, Option(name), props, recordHandler)
     }
 

Original file line number	Diff line number	Diff line change
`@@ -1340,7 +1340,7 @@ class SparkSqlAstBuilder(conf: SQLConf) extends AstBuilder {`
`1340`	`1340`	`val name = conf.getConfString("hive.script.serde",`
`1341`	`1341`	`"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe")`
`1342`	`1342`	`val props = Seq("field.delim" -> "\t")`
`1343`		`- val recordHandler = defaultRecordHandler(configKey)`
	`1343`	`+ val recordHandler = Try(conf.getConfString(configKey, configValue)).toOption`
`1344`	`1344`	`(Nil, Option(name), props, recordHandler)`
`1345`	`1345`	`}`
`1346`	`1346`