diff options
Diffstat (limited to 'sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala')
-rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala index 014c1009ed..8b4e4dced8 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveCommandSuite.scala @@ -239,12 +239,12 @@ class HiveCommandSuite extends QueryTest with SQLTestUtils with TestHiveSingleto } // Unset default URI Scheme and Authority: throw exception - val originalFsName = hiveContext.sparkContext.hadoopConfiguration.get("fs.default.name") - hiveContext.sparkContext.hadoopConfiguration.unset("fs.default.name") + val originalFsName = hiveContext.sessionState.hadoopConf.get("fs.default.name") + hiveContext.sessionState.hadoopConf.unset("fs.default.name") intercept[AnalysisException] { sql(s"""LOAD DATA INPATH "$testData" INTO TABLE non_part_table""") } - hiveContext.sparkContext.hadoopConfiguration.set("fs.default.name", originalFsName) + hiveContext.sessionState.hadoopConf.set("fs.default.name", originalFsName) } } } |