aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorwm624@hotmail.com <wm624@hotmail.com>2016-09-03 13:52:55 -0700
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2016-09-03 13:56:20 -0700
commite9b58e9ef89a9118b6d5a466d10db8e30d61f850 (patch)
treedd9844088f58ecd630cd0ab9dc8713e2e1de4a7d
parentabb2f921036d97d8cab033838ae559eb731bf0fd (diff)
downloadspark-e9b58e9ef89a9118b6d5a466d10db8e30d61f850.tar.gz
spark-e9b58e9ef89a9118b6d5a466d10db8e30d61f850.tar.bz2
spark-e9b58e9ef89a9118b6d5a466d10db8e30d61f850.zip
[SPARK-16829][SPARKR] sparkR sc.setLogLevel doesn't work
(Please fill in changes proposed in this fix) ./bin/sparkR Launching java with spark-submit command /Users/mwang/spark_ws_0904/bin/spark-submit "sparkr-shell" /var/folders/s_/83b0sgvj2kl2kwq4stvft_pm0000gn/T//RtmpQxJGiZ/backend_porte9474603ed1e Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties Setting default log level to "WARN". To adjust logging level use sc.setLogLevel(newLevel). > sc.setLogLevel("INFO") Error: could not find function "sc.setLogLevel" sc.setLogLevel doesn't exist. R has a function setLogLevel. I rename the setLogLevel function to sc.setLogLevel. (Please explain how this patch was tested. E.g. unit tests, integration tests, manual tests) Change unit test. Run unit tests. Manually tested it in sparkR shell. Author: wm624@hotmail.com <wm624@hotmail.com> Closes #14433 from wangmiao1981/sc.
-rw-r--r--core/src/main/scala/org/apache/spark/internal/Logging.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/internal/Logging.scala b/core/src/main/scala/org/apache/spark/internal/Logging.scala
index 66a0cfec62..013cd1c1bc 100644
--- a/core/src/main/scala/org/apache/spark/internal/Logging.scala
+++ b/core/src/main/scala/org/apache/spark/internal/Logging.scala
@@ -135,7 +135,8 @@ private[spark] trait Logging {
val replLevel = Option(replLogger.getLevel()).getOrElse(Level.WARN)
if (replLevel != rootLogger.getEffectiveLevel()) {
System.err.printf("Setting default log level to \"%s\".\n", replLevel)
- System.err.println("To adjust logging level use sc.setLogLevel(newLevel).")
+ System.err.println("To adjust logging level use sc.setLogLevel(newLevel). " +
+ "For SparkR, use setLogLevel(newLevel).")
rootLogger.setLevel(replLevel)
}
}