[SPARK-2339] SQL parser in sql-core is case sensitive, but a table alias is converted to lower case when we create Subquery

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.2, 1.1.0
• Component/s: SQL
• Target Version/s: 1.1.0
• Assignee: Yin Huai
• Reporter: Yin Huai
• Created: 01/Jul/14 20:59
• Updated: 12/Oct/15 03:14
• Resolved: 08/Jul/14 00:02

Description

Reported by http://apache-spark-user-list.1001560.n3.nabble.com/Spark-SQL-Join-throws-exception-td8599.html

After we get the table from the catalog, because the table has an alias, we will temporarily insert a Subquery. Then, we convert the table alias to lower case no matter if the parser is case sensitive or not.

To see the issue ...

val sqlContext = new org.apache.spark.sql.SQLContext(sc)
import sqlContext.createSchemaRDD

case class Person(name: String, age: Int)

val people = sc.textFile("examples/src/main/resources/people.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt))
people.registerAsTable("people")

sqlContext.sql("select PEOPLE.name from people PEOPLE")

The plan is ...

== Query Plan ==
Project ['PEOPLE.name]
 ExistingRdd [name#0,age#1], MapPartitionsRDD[4] at mapPartitions at basicOperators.scala:176

You can find that "PEOPLE.name" is not resolved.

Issue Links

• links to: Pull request