File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
core/src/main/scala/org/apache/spark/sql
hive/src/test/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -50,8 +50,8 @@ private[spark] object SQLConf {
50
50
trait SQLConf {
51
51
import SQLConf ._
52
52
53
- @ transient protected [spark] val settings = java.util. Collections .synchronizedMap(
54
- new java.util.HashMap [String , String ]())
53
+ @ transient protected [spark] val settings =
54
+ new java.util.concurrent. ConcurrentHashMap [String , String ]
55
55
56
56
/** ************************ Spark SQL Params/Hints ******************* */
57
57
// TODO: refactor so that these hints accessors don't pollute the name space of SQLContext?
Original file line number Diff line number Diff line change @@ -473,7 +473,7 @@ class HiveQuerySuite extends HiveComparisonTest {
473
473
474
474
sql(s " SET ${testKey + testKey}= ${testVal + testVal}" )
475
475
assert(hiveconf.get(testKey + testKey, " " ) == testVal + testVal)
476
- assertResult(Array (s " $testKey = $testVal " , s " ${testKey + testKey}= ${testVal + testVal}" )) {
476
+ assertResult(Array ( s " ${testKey + testKey}= ${testVal + testVal}" , s " $testKey = $testVal " )) {
477
477
sql(s " SET " ).collect().map(_.getString(0 ))
478
478
}
479
479
@@ -501,7 +501,7 @@ class HiveQuerySuite extends HiveComparisonTest {
501
501
502
502
sql(s " SET ${testKey + testKey}= ${testVal + testVal}" )
503
503
assert(hiveconf.get(testKey + testKey, " " ) == testVal + testVal)
504
- assertResult(Array (s " $testKey = $testVal " , s " $ {testKey + testKey}= ${testVal + testVal}" )) {
504
+ assertResult(Array (s " ${testKey + testKey}= ${testVal + testVal}" , s " $testKey = $testVal " )) {
505
505
sql(" SET" ).collect().map(_.getString(0 ))
506
506
}
507
507
You can’t perform that action at this time.
0 commit comments