diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csvExpressions.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csvExpressions.scala index 348433535369..a63b6245c499 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csvExpressions.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csvExpressions.scala @@ -78,8 +78,7 @@ case class CsvToStructs( @transient lazy val converter = (rows: Iterator[InternalRow]) => { if (rows.hasNext) { - rows.next() - val result = rows.next + val result = rows.next() // CSV's parser produces one record only. assert(!rows.hasNext) result diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVUtilsSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVExprUtilsSuite.scala similarity index 97% rename from sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVUtilsSuite.scala rename to sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVExprUtilsSuite.scala index 1133b3d3355d..838ac42184fa 100644 --- a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVUtilsSuite.scala +++ b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/csv/CSVExprUtilsSuite.scala @@ -19,7 +19,7 @@ package org.apache.spark.sql.catalyst.csv import org.apache.spark.SparkFunSuite -class CSVExpressionUtilsSuite extends SparkFunSuite { +class CSVExprUtilsSuite extends SparkFunSuite { test("Can parse escaped characters") { assert(CSVExprUtils.toChar("""\t""") === '\t') assert(CSVExprUtils.toChar("""\r""") === '\r')