Skip to content

Commit 0d91c0a

Browse files
committed
Also recognize Default.Src, etc
1 parent 7ecd9f5 commit 0d91c0a

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveComparisonTest.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,9 @@ abstract class HiveComparisonTest
287287
for (table <- Seq("src", "srcpart")) {
288288
val hasMatchingQuery = queryList.exists { query =>
289289
val normalizedQuery = query.toLowerCase.stripSuffix(";")
290-
normalizedQuery.endsWith(table) || normalizedQuery.contains(s"from $table")
290+
normalizedQuery.endsWith(table) ||
291+
normalizedQuery.contains(s"from $table") ||
292+
normalizedQuery.contains(s"from default.$table")
291293
}
292294
if (hasShowTableCommand || hasMatchingQuery) {
293295
TestHive.loadTestTable(table)

0 commit comments

Comments
 (0)