如何控制Flink代码运行时控制日志级别

在Flink程序中，可以通过设置日志级别来控制控制台输出的信息。要让控制台只打印结果信息，可以将日志级别设置为

ERROR

。这样，只有错误信息和

print()

方法输出的结果会显示在控制台上。

要设置日志级别，请在Flink项目的

resources

目录下创建一个名为

log4j.properties

的文件（如果已经存在，请修改相应的配置）。将以下内容添加到

log4j.properties

文件中：

log4j.rootLogger=ERROR, console
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n

这将把日志级别设置为

ERROR

，并将日志输出到控制台。在这种配置下，控制台将只显示错误信息和

print()

方法输出的结果。

注意：如果项目中使用的是

logback

而不是

log4j

，则需要创建或修改

logback.xml

文件，如下所示：

<configuration><appendername="console"class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern></encoder></appender><rootlevel="ERROR"><appender-refref="console"/></root></configuration>

这将把日志级别设置为

ERROR

，并将日志输出到控制台。在这种配置下，控制台将只显示错误信息和

print()

方法输出的结果。