Skip to content

[SPARK-6618][SPARK-6669][SQL] Lock Hive metastore client correctly. #5333

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
yhuai wants to merge 7 commits into from
Closed

[SPARK-6618][SPARK-6669][SQL] Lock Hive metastore client correctly. #5333

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
5416b0f
Just protect client.
yhuai Mar 31, 2015
fee7e9c
A test?
yhuai Mar 31, 2015
1e241af
Protect InsertIntoHive.
yhuai Apr 2, 2015
d6fc32f
Missing `)`.
yhuai Apr 2, 2015
e4a9b0b
Correctly lock on MetastoreCatalog
marmbrus Apr 2, 2015
7667030
Merge pull request #2 from marmbrus/pr/5333
yhuai Apr 2, 2015
59c884f
[SQL] Lock metastore client in analyzeTable
marmbrus Apr 2, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
A test?
  • Loading branch information
@yhuai
yhuai committed Apr 2, 2015
commit fee7e9cf870893e47bc9b40ef7ceebffe1c8efd8
11 changes: 11 additions & 0 deletions sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -457,4 +457,15 @@ class SQLQuerySuite extends QueryTest {
dropTempTable("data")
setConf("spark.sql.hive.convertCTAS", originalConf)
}

test("sanity test for SPARK-6618") {
(1 to 100).par.map { i =>
val tableName = s"SPARK_6618_table_$i"
sql(s"CREATE TABLE $tableName (col1 string)")
catalog.lookupRelation(Seq(tableName))
table(tableName)
tables()
sql(s"DROP TABLE $tableName")
}
}
}