fix

apache · Aug 27, 2018 · 83387f6 · 83387f6
1 parent bd3f502
commit 83387f6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveHints.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveHints.scala
@@ -62,15 +62,11 @@ object ResolveHints {
       }
     }
 
-    private def formatDatabaseName(name: String): String = {
-      if (conf.caseSensitiveAnalysis) name else name.toLowerCase(Locale.ROOT)
-    }
-
     private def matchedTableIdentifier(
         nameParts: Seq[String],
         tableIdent: IdentifierWithDatabase): Boolean = {
       tableIdent.database match {
-        case Some(db) if catalog.globalTempViewManager.database == formatDatabaseName(db) =>
+        case Some(db) if resolver(catalog.globalTempViewManager.database, db) =>
           val identifierList = db :: tableIdent.identifier :: Nil
           namePartsWithDatabase(nameParts, catalog.globalTempViewManager.database)
             .corresponds(identifierList)(resolver)

diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/ResolveHintsSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/ResolveHintsSuite.scala
@@ -163,5 +163,11 @@ class ResolveHintsSuite extends AnalysisTest {
       Join(ResolvedHint(testRelation, HintInfo(broadcast = true)),
         ResolvedHint(testRelation2, HintInfo(broadcast = true)), Inner, None),
       caseSensitive = false)
+
+    checkAnalysis(
+      UnresolvedHint("MAPJOIN", Seq("default.TaBlE", "default.table2", "DEfault.TaBlE2"),
+        table("TaBlE").join(table("TaBlE2"))),
+      Join(ResolvedHint(testRelation, HintInfo(broadcast = true)), testRelation2, Inner, None),
+      caseSensitive = true)
   }
 }