From d116405a69bc828c7da55ce12e0d2b2cf741bbb1 Mon Sep 17 00:00:00 2001 From: wangfei Date: Wed, 8 Oct 2014 00:23:07 +0800 Subject: [PATCH] make sure that log4j level is INFO --- .../sql/hive/thriftserver/HiveThriftServer2Suite.scala | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suite.scala b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suite.scala index e58a0edde6df2..e67ecf858ae5d 100644 --- a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suite.scala +++ b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suite.scala @@ -23,6 +23,7 @@ import java.sql.{DriverManager, Statement} import java.util.concurrent.TimeoutException import scala.collection.mutable.ArrayBuffer +import scala.collection.JavaConversions._ import scala.concurrent.duration._ import scala.concurrent.{Await, Promise} import scala.sys.process.{Process, ProcessLogger} @@ -42,7 +43,12 @@ class HiveThriftServer2Suite extends FunSuite with Logging { Class.forName(classOf[HiveDriver].getCanonicalName) val verbose = Option(System.getenv("SPARK_SQL_TEST_VERBOSE")).isDefined - + // Since we use info to assert server process started successfully, + // make sure that log4j level is INFO + org.apache.log4j.LogManager.getCurrentLoggers.foreach { log => + log.asInstanceOf[org.apache.log4j.Logger].setLevel(org.apache.log4j.Level.INFO) + } + def startThriftServerWithin(timeout: FiniteDuration = 1.minute)(f: Statement => Unit) { Thread.sleep(5000)