@@ -72,14 +72,14 @@ class CSVSuite extends QueryTest with SharedSQLContext with SQLTestUtils {
7272 if (withHeader) {
7373 assert(df.schema.fieldNames === Array (" year" , " make" , " model" , " comment" , " blank" ))
7474 } else {
75- assert(df.schema.fieldNames === Array (" C0 " , " C1 " , " C2 " , " C3 " , " C4 " ))
75+ assert(df.schema.fieldNames === Array (" _c0 " , " _c1 " , " _c2 " , " _c3 " , " _c4 " ))
7676 }
7777 }
7878
7979 if (checkValues) {
8080 val yearValues = List (" 2012" , " 1997" , " 2015" )
8181 val actualYears = if (! withHeader) " year" :: yearValues else yearValues
82- val years = if (withHeader) df.select(" year" ).collect() else df.select(" C0 " ).collect()
82+ val years = if (withHeader) df.select(" year" ).collect() else df.select(" _c0 " ).collect()
8383
8484 years.zipWithIndex.foreach { case (year, index) =>
8585 if (checkTypes) {
@@ -232,8 +232,8 @@ class CSVSuite extends QueryTest with SharedSQLContext with SQLTestUtils {
232232 .load(testFile(carsBlankColName))
233233
234234 assert(cars.select(" customer" ).collect().size == 2 )
235- assert(cars.select(" C0 " ).collect().size == 2 )
236- assert(cars.select(" C1 " ).collect().size == 2 )
235+ assert(cars.select(" _c0 " ).collect().size == 2 )
236+ assert(cars.select(" _c1 " ).collect().size == 2 )
237237 }
238238
239239 test(" test for FAILFAST parsing mode" ) {
0 commit comments