Skip to content

Commit 9c32b5b

Browse files
authored
Merge pull request apache#371 from palantir/jt/fix-case-sensitive-literals
[SPARK-24151] fix case sensitive literals
2 parents c411602 + afedce0 commit 9c32b5b

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -981,7 +981,7 @@ class Analyzer(
981981
// support CURRENT_DATE and CURRENT_TIMESTAMP
982982
val literalFunctions = Seq(CurrentDate(), CurrentTimestamp())
983983
val name = nameParts.head
984-
val func = literalFunctions.find(e => resolver(e.prettyName, name))
984+
val func = literalFunctions.find(e => caseInsensitiveResolution(e.prettyName, name))
985985
func.map(wrapper)
986986
}
987987

sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -631,6 +631,14 @@ class SQLQuerySuite extends QueryTest with SharedSQLContext {
631631
}
632632
}
633633

634+
test("current_date with case sensitive") {
635+
withSQLConf(SQLConf.CASE_SENSITIVE.key -> "true") {
636+
checkAnswer(
637+
sql("SELECT DATEDIFF(CURRENT_DATE, current_date)"),
638+
Row(0))
639+
}
640+
}
641+
634642
test("inner join where, one match per row") {
635643
withSQLConf(SQLConf.CASE_SENSITIVE.key -> "true") {
636644
checkAnswer(

0 commit comments

Comments
 (0)