diff options
Diffstat (limited to 'sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala b/sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala index f683bbbeb5..04ad729659 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala @@ -21,6 +21,8 @@ import java.util.Properties import scala.collection.JavaConverters._ +import org.apache.hadoop.conf.Configuration + import org.apache.spark.internal.config.ConfigEntry import org.apache.spark.sql._ import org.apache.spark.sql.catalyst.analysis.{Analyzer, FunctionRegistry} @@ -46,6 +48,7 @@ private[sql] class SessionState(ctx: SQLContext) { * SQL-specific key-value configurations. */ lazy val conf: SQLConf = new SQLConf + lazy val hadoopConf: Configuration = new Configuration(ctx.sparkContext.hadoopConfiguration) // Automatically extract `spark.sql.*` entries and put it in our SQLConf setConf(SQLContext.getSQLProperties(ctx.sparkContext.getConf)) |