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 index eb9ce877fc8d..74e8a3247925 100644 --- 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 @@ -299,10 +299,10 @@ class HadoopTableReader( */ private def createHadoopRDD(localTableDesc: TableDesc, inputPathStr: String): RDD[Writable] = { val inputFormatClazz = localTableDesc.getInputFileFormatClass - if (classOf[newInputClass[_, _]].isAssignableFrom(inputFormatClazz)) { - createNewHadoopRDD(localTableDesc, inputPathStr) - } else { + if (classOf[oldInputClass[_, _]].isAssignableFrom(inputFormatClazz)) { createOldHadoopRDD(localTableDesc, inputPathStr) + } else { + createNewHadoopRDD(localTableDesc, inputPathStr) } }