fix test failed

apache · Mar 1, 2017 · 2456a94 · 2456a94
1 parent f83d81d
commit 2456a94
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
@@ -111,14 +111,13 @@ class HadoopTableReader(
 
     // Create local references to member variables, so that the entire `this` object won't be
     // serialized in the closure below.
-    val localTableDesc = tableDesc
     val broadcastedHadoopConf = _broadcastedHadoopConf
 
     val tablePath = hiveTable.getPath
     val inputPathStr = applyFilterIfNeeded(tablePath, filterOpt)
 
     val locationPath = new Path(inputPathStr)
-    val fs = locationPath.getFileSystem(broadcastedHadoopConf.value.value)
+    val fs = locationPath.getFileSystem(_broadcastedHadoopConf.value.value)
 
     // if the location of the table which is not created by 'stored by' does not exist,
     // return an empty RDD