diff --git a/core/src/main/scala/org/apache/spark/Logging.scala b/core/src/main/scala/org/apache/spark/Logging.scala index db62055bf58a7..3b1b7c31fb136 100644 --- a/core/src/main/scala/org/apache/spark/Logging.scala +++ b/core/src/main/scala/org/apache/spark/Logging.scala @@ -136,6 +136,6 @@ trait Logging { private object Logging { @volatile private var initialized = false val initLock = new Object() - SLF4JBridgeHandler.removeHandlersForRootLogger() - SLF4JBridgeHandler.install() + // SLF4JBridgeHandler.removeHandlersForRootLogger() + if(!SLF4JBridgeHandler.isInstalled) SLF4JBridgeHandler.install() }