配置时，谷歌云数据流 Eclipse 插件无法显示 TRACE 日志或以下错误的任何日志

Question

当我按照文档配置将 workerLogLevelOverrides 设置为 {\"com.mycompany.testdataflow.StarterPipeline\":\"TRACE\"} 的 google cloud dataflow eclipse 插件时，我无法看到日志

奇怪的是，错误级别的配置似乎显示了日志，但任何更低的都不会。

有人遇到过这个吗？

这是我用来尝试输出日志的代码段

私有静态最终Logger LOG = LoggerFactory.getLogger(StarterPipeline.class);

public static void main(String[] args) {
    Pipeline p = Pipeline.create(PipelineOptionsFactory.fromArgs(args).withValidation().create());

    for (String string : args) {
        // System.out.println("########## "+string);
        LOG.trace("Doing the trace for pipeline ##### Parameter is #### " + string);

        LOG.trace("Doing the trace for pipeline ##### Parameter is #### ");
    }

    LOG.trace("Doing the trace for pipeline");
    p.apply(Create.of("Hello", "World")).apply(ParDo.of(new DoFn<String, String>() {
        @Override
        public void processElement(ProcessContext c) {
            LOG.trace("Doing the trace for pipeline");
            c.output(c.element().toUpperCase());
        }
    })).apply(ParDo.of(new DoFn<String, Void>() {
        @Override
        public void processElement(ProcessContext c) {
            LOG.trace("Doing the trace for pipeline");
            LOG.info(c.element());
        }
    }));

这来自数据流示例，除了我添加的日志以查看我是否能够看到任何日志。

Answer 1

使用BlockingDataflowPipelineRunner 或DataflowPipelineRunner 运行管道时，需要执行两个部分。首先，您的主要方法在您的机器上本地运行以生成管道。当您调用 p.run() 时，管道将被发送到 Dataflow 服务，并在该服务上运行（可能很多）虚拟机。

直接在main 方法中的日志语句（例如“Doing the trace for pipeline ...”）发生在您的机器上，并将显示在 Eclipse 控制台中。 DoFns 中的日志语句发生在虚拟机上，并且仅显示在 Cloud Logging 中，如 DebuggingWordCount example 中所述。

指定workerLogLevelOverrides 会影响工作虚拟机的日志级别。因此，更改该值将影响 DoFns 记录到 Cloud Logging 的内容。

要调整您机器上运行的代码的日志级别（即main 方法），您需要调整运行主程序的 SLF4J 或 java.util.logging 日志级别。例如，these instructions on Stack Overflow 建议使用日志配置文件。