设置Apache Storm和Flink日志级别以显示调试消息

问题描述 投票:0回答:1

因此,我正在使用Storm和Flink应用程序构建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消息仅来自我的软件包

[我尝试了几件事,但我觉得我只是在尝试从互联网上随机抽取的东西,因为我找不到有关如何获得此东西的权威参考,而且我很难把头围在令人难以置信的令人困惑的状态上。 Java的日志设施...

我同时询问Storm和Flink,因为我怀疑问题的根源相同,但我可能错了。我也很抱歉,如果我没有提供一个最小的示例,但这里实际上没有任何提供。

[如果需要其他详细信息,请告诉我。

java logging apache-flink apache-storm
1个回答
0
投票

对于Storm,您的日志配置位于storm/log4j2/worker.xml中。这是一个log4j2配置文件,因此您可以通过在此处https://logging.apache.org/log4j/2.x/manual/configuration.html上查看log4j2文档来找出有哪些选项。

我对Flink不太熟悉,但我怀疑它是相似的。 Here是Flink的页面,其中提到logback.xml目录中应该有一个conf文件。

© www.soinside.com 2019 - 2024. All rights reserved.