因此，我正在用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支持动态加载设置。