Skip to content

Commit d116405

Browse files
scwfliancheng
authored andcommitted
make sure that log4j level is INFO
1 parent ee92a82 commit d116405

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suite.scala

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import java.sql.{DriverManager, Statement}
2323
import java.util.concurrent.TimeoutException
2424

2525
import scala.collection.mutable.ArrayBuffer
26+
import scala.collection.JavaConversions._
2627
import scala.concurrent.duration._
2728
import scala.concurrent.{Await, Promise}
2829
import scala.sys.process.{Process, ProcessLogger}
@@ -42,7 +43,12 @@ class HiveThriftServer2Suite extends FunSuite with Logging {
4243
Class.forName(classOf[HiveDriver].getCanonicalName)
4344

4445
val verbose = Option(System.getenv("SPARK_SQL_TEST_VERBOSE")).isDefined
45-
46+
// Since we use info to assert server process started successfully,
47+
// make sure that log4j level is INFO
48+
org.apache.log4j.LogManager.getCurrentLoggers.foreach { log =>
49+
log.asInstanceOf[org.apache.log4j.Logger].setLevel(org.apache.log4j.Level.INFO)
50+
}
51+
4652
def startThriftServerWithin(timeout: FiniteDuration = 1.minute)(f: Statement => Unit) {
4753
Thread.sleep(5000)
4854

0 commit comments

Comments
 (0)