因此,我正在用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。。。
我问的是风暴和Flink,因为我怀疑我的问题的根源是相同的,但我可能是错的。我也很抱歉,如果我没有提供一个最小的例子,但这里真的没有什么可以提供。
请让我知道如果你需要更多的细节。
3条答案
按热度按时间vu8f3i0k1#
在这种情况下:
然后我把jar递给他
.../bin/storm
以及.../bin/flink
脚本和一切工作,但日志级别设置为INFO
,我还想展示DEBUG
仅来自我的包的消息。我最终得到了以下次优的解决方案。
风暴
不知什么原因
/path/to/storm/log4j2/worker.xml
文件无效,因此我需要以编程方式操作:Flink
加一行就够了
/path/to/flink/conf/log4j.properties
:stszievb2#
对于storm,您的日志配置位于
storm/log4j2/worker.xml
. 它是一个log4j2配置文件,因此您可以通过查看这里的log4j2文档来了解有哪些选项https://logging.apache.org/log4j/2.x/manual/configuration.html.我对Flink不太熟悉,但我怀疑是相似的。这是Flink的网页,上面提到你应该
logback.xml
文件在您的conf
目录。hvvq6cgz3#
为了修改日志级别以及哪些类登录到flink集群,请进行调整
FLINK_HOME/conf/log4j.properties
如果您正在使用log4j
FLINK_HOME/conf/logback.xml
如果您正在使用logback
在你启动flink集群之前。部署flink集群时将读取这些文件。请注意,这些设置不能在运行时更改,除非您正在替换flink的设置
log4j
记录器log4j2
支持动态加载设置。