scala的文件名中追加spark applicationid

eh57zj3b 于 2021-05-27 发布在 Spark

关注(0)|答案(1)|浏览(372)

我正在尝试将spark applicationid附加到log4j日志文件的文件名。下面是log4j.properties文件

log4j.rootLogger=info,file

# Redirect log messages to console

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L -%m%n

# Redirect log messages to log file, support file rolling

log4j.appender.file=org.apache.log4j.rolling.RollingFileAppender
log4j.appender.file.rollingPolicy=org.apache.log4j.rolling.TimeBasedRollingPolicy
log4j.appender.file.rollingPolicy.FileNamePattern=log4j//Data_Quality.%d{yyyy-MM-dd}.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L -%m%n

# set the immediate flush to true

log4j.appender.FILE.ImmediateFlush=true

# set the threshold to debug mode INFO

log4j.appender.FILE.Threshold=INFO

# Set the append to false, overwrite

log4j.appender.FILE.Append=true

spark提交命令：

spark2-submit -conf "spark.driver.extraJavaOptions=-Dconfig.file=./input.conf -Dlog4j.configuration=log4j.properties" --conf "spark.executor.extraJavaOptions=-Dlog4j.configuration=log4j.properties" --files "input.conf,log4j.properties" --master yarn --class "DataCheckImplementation" Data_quality.jar

创建的日志文件名为：data_quality.2020-07-21.log，工作正常。
我想将spark applicationid添加到文件名预期文件名：data\u quality.（applicationid）.2020-07-21.log
示例：数据\质量（应用程序\ 1595144411765 \ 20000）.2020-07-21.log
有可能吗？需要帮助！

scala apache-spark Log4j

来源：https://stackoverflow.com/questions/63025600/how-to-append-spark-applicationid-in-filename-of-log4j-log-file-scala

1条答案

按热度按时间

brccelvz1#

我不知道/认为这是否可以在配置级别实现（例如lo4j.properties等），但是我们可以通过一些方法实现这一点。这里有一种方法：
您将需要有一个logger类/特性来处理所有的logger管理，例如：

trait SparkContextProvider {
 def spark: SparkSession
}

trait Logger extends SparkContextProvider {

lazy val log = Logger.getLogger(...)

lazy val applicationId = spark.sparkContext.applicationId

val appender = new RollingFileAppender();
        appender.setAppend(true);
        appender.setMaxFileSize("1MB");
        appender.setMaxBackupIndex(1);
        appender.setFile("Data_Quality" + applicationId + "_" + dateFormat.format(date) + ".log");
        appender.activateOptions();

        val layOut = new PatternLayout();
        layOut.setConversionPattern("%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n");
        appender.setLayout(layOut);

        log.addAppender(appender);
}

赞(0）回复(0）举报 2021-05-27

我来回答

scala的文件名中追加spark applicationid

1条答案

相关问题

热门标签

最新问答