From 7a37b55bfa93b7de04b686c19d38707867d61909 Mon Sep 17 00:00:00 2001 From: Ferenc Csaky Date: Fri, 6 Feb 2026 13:07:36 +0100 Subject: [PATCH] Do not show REST not found errors in log --- .../src/main/resources/log4j2.properties | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) 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