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 e28d23f2ce08..e3b4e45a3d68 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 @@ -41,13 +41,10 @@ import org.apache.spark.sql.catalyst.util.getTempFilePath class HiveThriftServer2Suite extends FunSuite with Logging { Class.forName(classOf[HiveDriver].getCanonicalName) - val verbose = Option(System.getenv("SPARK_SQL_TEST_VERBOSE")).isDefined - def startThriftServerWithin(timeout: FiniteDuration = 1.minute)(f: Statement => Unit) { - Thread.sleep(5000) - val startScript = "../../sbin/start-thriftserver.sh".split("/").mkString(File.separator) val stopScript = "../../sbin/stop-thriftserver.sh".split("/").mkString(File.separator) + val warehousePath = getTempFilePath("warehouse") val metastorePath = getTempFilePath("metastore") val metastoreJdbcUri = s"jdbc:derby:;databaseName=$metastorePath;create=true" @@ -94,8 +91,9 @@ class HiveThriftServer2Suite extends FunSuite with Logging { .run(ProcessLogger(captureLogOutput, _ => ())) } } - // reset SPARK_TESTING to avoid loading Log4J configurations in testing class paths - Process(command, None, ("SPARK_TESTING", "0")).run(ProcessLogger( + + // Resets SPARK_TESTING to avoid loading Log4J configurations in testing class paths + Process(command, None, "SPARK_TESTING" -> "0").run(ProcessLogger( captureThriftServerOutput("stdout"), captureThriftServerOutput("stderr"))) diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TestHive.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TestHive.scala index 66ce64a696fd..a4354c1379c6 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TestHive.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TestHive.scala @@ -378,6 +378,11 @@ class TestHiveContext(sc: SparkContext) extends HiveContext(sc) { */ def reset() { try { + // HACK: Hive is too noisy by default. + org.apache.log4j.LogManager.getCurrentLoggers.foreach { log => + log.asInstanceOf[org.apache.log4j.Logger].setLevel(org.apache.log4j.Level.WARN) + } + clearCache() loadedTables.clear() catalog.client.getAllTables("default").foreach { t =>