diff --git a/flink-sql-runner/src/main/resources/log4j2.properties b/flink-sql-runner/src/main/resources/log4j2.properties index 807da87a..12bb1b55 100644 --- a/flink-sql-runner/src/main/resources/log4j2.properties +++ b/flink-sql-runner/src/main/resources/log4j2.properties @@ -21,7 +21,11 @@ appender.console.target = SYSTEM_OUT appender.console.layout.type = PatternLayout appender.console.layout.pattern = %d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n -# Set general Flink log level to WARN +# Root logger +rootLogger.level = INFO +rootLogger.appenderRef.console.ref = Console + +# Set the general Flink log level to WARN logger.flink.name = org.apache.flink logger.flink.level = WARN @@ -40,6 +44,8 @@ logger.hadoopUtils.level = ERROR logger.hadoopNativeCode.name = org.apache.hadoop.util.NativeCodeLoader logger.hadoopNativeCode.level = ERROR -# Root logger -rootLogger.level = INFO -rootLogger.appenderRef.console.ref = Console +# Filters out REST not found errors +rootLogger.filter.jobNotFound.type = RegexFilter +rootLogger.filter.jobNotFound.regex = .*Exception occurred in REST handler: Job \\S+ not found.* +rootLogger.filter.jobNotFound.onMatch = DENY +rootLogger.filter.jobNotFound.onMismatch = NEUTRAL