因此，我正在使用 Storm 和 Flink 應用程序構(gòu)建一個 JAR，其中記錄消息如下：import org.slf4j.Logger;import org.slf4j.LoggerFactory;// ...private static final Logger LOG = LoggerFactory.getLogger(Some.class);// ...LOG.debug("...");LOG.info("...");LOG.error("...");然后我將 JAR 傳遞給.../bin/storm腳本.../bin/flink，一切正常，但日志級別設置為INFO，我還想僅顯示來自我的包的DEBUG消息。我嘗試了幾件事，但我覺得我只是從互聯(lián)網(wǎng)上嘗試隨機的事情，因為我找不到關(guān)于如何獲取它的權(quán)威參考，而且我很難理解日志設施令人難以置信的混亂狀態(tài)對于Java...我詢問 Storm 和 Flink，因為我懷疑問題的根源是相同的，但我可能是錯的。如果我沒有提供一個最小的例子，我也很抱歉，但這里確實沒有什么可提供的。如果您需要更多詳細信息，請告訴我。
3 回答
慕仙森
TA貢獻1827條經(jīng)驗 獲得超8個贊
為了修改Flink集群上的日志級別和哪些類日志，請修改
FLINK_HOME/conf/log4j.properties如果你正在使用log4jFLINK_HOME/conf/logback.xml如果你正在使用logback
在啟動 Flink 集群之前。
當您部署 Flink 集群時，將會讀取這些文件。請注意，這些設置無法在運行時更改，除非您將 Flink 的log4j記錄器替換為log4j2支持動態(tài)加載設置的記錄器。
翻翻過去那場雪
TA貢獻2065條經(jīng)驗 獲得超14個贊
對于 Storm，您的日志配置位于storm/log4j2/worker.xml. 這是一個 log4j2 配置文件，因此您可以通過查看此處的 log4j2 文檔來了解有哪些選項：https: //logging.apache.org/log4j/2.x/manual/configuration.html。
我對 Flink 不太熟悉，但我懷疑它是相似的。這是 Flink 的頁面，其中提到您logback.xml的目錄中應該有一個文件conf。
白豬掌柜的
TA貢獻1893條經(jīng)驗 獲得超10個贊
在這種情況下：
然后我將 JAR 傳遞給.../bin/storm腳本.../bin/flink，一切正常，但日志級別設置為INFO，我還想僅顯示來自我的包的DEBUG消息。
我最終得到了以下次優(yōu)解決方案。
風暴
由于未知原因，更改/path/to/storm/log4j2/worker.xml文件沒有任何效果，因此我需要以編程方式執(zhí)行操作：
import org.apache.logging.log4j.Level;
import org.apache.logging.log4j.core.config.Configurator;
// ...
Configurator.setLevel("my.package", Level.ALL);
大量
添加一行就足夠了/path/to/flink/conf/log4j.properties：
log4j.logger.my.package=ALL
添加回答
舉報
0/150
提交
取消