我如何添加自定義的登錄數據磚嗎

[User16869510359]

我想添加自定義日誌重定向的火花司機日誌。我可以使用現有的logger類有應用程序日誌或進展消息引發司機日誌中。

[User16869510359 · Accepted solution]

設置自定義日誌消息在Scala中:

% scala org.slf4j進口。{記錄器,LoggerFactory} val customlog = LoggerFactory.getLogger (customlog) customLogs.info customlog(“測試信息日誌”)。警告customlog(“測試警告日誌”)。錯誤(“測試錯誤日誌”)打印(“這消息將在stdout而不是log4j”)

在Python中設置自定義日誌消息

% python log4jLogger = spark.sparkContext._jvm.org.apache.log4j customlog = log4jLogger.LogManager.getLogger (customlog) customLogs.info customlog(“測試信息日誌”)。警告customlog(“測試警告日誌”)。錯誤(“測試錯誤日誌”)打印(“這消息將在stdout而不是log4j”)