From 8bb6ffdcae9394e414f3897450a43fa640882f99 Mon Sep 17 00:00:00 2001 From: witgo Date: Mon, 7 Apr 2014 01:35:25 +0800 Subject: [PATCH] enableLogForwarding note fix --- .../org/apache/spark/sql/parquet/ParquetRelation.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetRelation.scala b/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetRelation.scala index 27917e223d923..dc03ea5082ce7 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetRelation.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetRelation.scala @@ -82,10 +82,8 @@ private[sql] case class ParquetRelation(val path: String) private[sql] object ParquetRelation { def enableLogForwarding() { - // Note: Parquet does not use forwarding to parent loggers which - // is required for the JUL-SLF4J bridge to work. Also there is - // a default logger that appends to Console which needs to be - // reset. + // Note: Logger.getLogger("parquet") has a default logger + // that appends to Console which needs to be cleared. val parquetLogger = java.util.logging.Logger.getLogger("parquet") parquetLogger.getHandlers.foreach(parquetLogger.removeHandler) if(parquetLogger.getLevel != null) parquetLogger.setLevel(null)