代码之家 › 专栏 › 技术社区 › user3725190

使用RedirectToLog的Spark启动程序不写入日志

apache-spark scala

2

user3725190 · 技术社区 · 7 年前

我使用SparkLauncher来提交Spark申请。我想将日志信息重定向到logback.xml定义的日志文件。我正在使用com.typesafe.scalalogging.lazylogging。

我试着这么做却没用:

val sparkLauncher: SparkLauncher = new SparkLauncher(envVariable)
      .setAppName("spark")
      .redirectToLog(this.getClass.getName)
      .setSparkHome(sparkInput.sparkHomePath)
      .setMaster(sparkInput.master)
      .setMainClass(sparkInput.classPath)
      .setAppResource(sparkInput.jarPath)
      .setVerbose(true) 
val sparkLauncher: SparkLauncher = buildSparkLauncher(sparkInput)
val p = sparkLauncher.launch()
p.waitFor()

0 回复 | 直到 7 年前