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

Question

因此，我正在使用 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，我还想显示仅来 self 的包的DEBUG消息。

我尝试了几件事，但我觉得我只是从互联网上尝试随机的事情，因为我找不到关于如何获得这个的权威引用，而且我很难理解令人难以置信的困惑状态Java 的日志工具...

我正在询问 Storm 和 Flink，因为我怀疑问题的根源是相同的，但我可能是错的。如果我没有提供一个最小的示例，我也深表歉意，但这里确实没有什么可提供的。

如果您需要更多详细信息，请告诉我。

Answer 1

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

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