diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala b/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala index 45af4d3d8043a..e097030b6629c 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala @@ -641,7 +641,7 @@ class JavaSparkContext(val sc: SparkContext) * @param logLevel The desired log level as a string. */ def setLoggingLevel(logLevel: String) = { - Utils.setLoggingLevel(org.apache.log4j.Level.toLevel(logLevel)) + sc.setLoggingLevel(logLevel) }