Skip to content

Commit

Permalink
Use a more mnemonic path for logging
Browse files Browse the repository at this point in the history
Also get rid of a couple of unused vals.
  • Loading branch information
andrewor14 committed Mar 4, 2014
1 parent aef411c commit bb4c503
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -54,8 +54,9 @@ private[ui] class GatewayUISparkListener(parent: SparkUI, sc: SparkContext) exte
private val logger: Option[FileLogger] = {
if (sc != null && sc.conf.getBoolean("spark.eventLog.enabled", false)) {
val logDir = sc.conf.get("spark.eventLog.dir", "/tmp/spark-events")
val appName = sc.appName.replaceAll("[ /]", "_").toLowerCase
val overwrite = sc.conf.getBoolean("spark.eventLog.overwrite", true)
Some(new FileLogger(logDir, overwriteExistingFiles = overwrite))
Some(new FileLogger(logDir, appName, overwriteExistingFiles = overwrite))
} else None
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,6 @@ import org.apache.spark.ui._
private[ui] class EnvironmentUI(parent: SparkUI) {
lazy val appName = parent.appName
lazy val listener = _listener.get
val live = parent.live
val sc = parent.sc

private var _listener: Option[EnvironmentListener] = None

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,6 @@ import org.apache.spark.util.Utils
private[ui] class ExecutorsUI(parent: SparkUI) {
lazy val appName = parent.appName
lazy val listener = _listener.get
val live = parent.live
val sc = parent.sc

private var _listener: Option[ExecutorsListener] = None

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,6 @@ import org.apache.spark.ui._
private[ui] class BlockManagerUI(parent: SparkUI) {
lazy val appName = parent.appName
lazy val listener = _listener.get
val live = parent.live
val sc = parent.sc

private val indexPage = new IndexPage(this)
private val rddPage = new RDDPage(this)
Expand Down

0 comments on commit bb4c503

Please sign in to comment.