File tree Expand file tree Collapse file tree 1 file changed +3
-7
lines changed
sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver Expand file tree Collapse file tree 1 file changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -56,13 +56,9 @@ trait SharedThriftServer extends SharedSparkSession {
5656 }
5757
5858 protected def jdbcUri : String = if (mode == ServerMode .http) {
59- s """ jdbc:hive2://localhost: $serverPort/
60- |default;
61- |transportMode=http;
62- |httpPath=cliservice
63- """ .stripMargin.split(" \n " ).mkString.trim
59+ s " jdbc:hive2://localhost: $serverPort/default;transportMode=http;httpPath=cliservice "
6460 } else {
65- s """ jdbc:hive2://localhost: $serverPort"" "
61+ s " jdbc:hive2://localhost: $serverPort"
6662 }
6763
6864 protected def withJdbcStatement (fs : (Statement => Unit )* ): Unit = {
@@ -102,7 +98,7 @@ trait SharedThriftServer extends SharedSparkSession {
10298 // Wait for thrift server to be ready to serve the query, via executing simple query
10399 // till the query succeeds. See SPARK-30345 for more details.
104100 eventually(timeout(30 .seconds), interval(1 .seconds)) {
105- withJdbcStatement {_.execute(" SELECT 1" )}
101+ withJdbcStatement { _.execute(" SELECT 1" ) }
106102 }
107103 } catch {
108104 case e : Exception =>
You can’t perform that action at this time.
0 commit comments