[
https://issues.apache.org/jira/browse/FLINK-37919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dheeraj Panangat updated FLINK-37919:
-------------------------------------
Description:
Below is the logback-console.xml being set in Flink :
{code:java}
<configuration debug="true" scan="true" scanPeriod="30 seconds">
<statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener"/>
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36}
- %msg%n</pattern>
</encoder>
</appender>
<logger name="io.company" level="INFO" additivity="false">
<appender-ref ref="CONSOLE"/>
</logger>
<logger name="com.company" level="INFO" additivity="false">
<appender-ref ref="CONSOLE"/>
</logger>
<root level="WARN">
<appender-ref ref="CONSOLE" />
</root>
</configuration> {code}
>From within a package {{com.company.processor.DummyClass.class}} I am logging
>2 statements,
1 with log.error() and other with log.info()
Expecting both to be printed, but only see the ERROR log being printed.
I have verified that the logback-console.xml is updated inside JM and TMs by
exec -it into the pods.
The dummy class
{code:java}
package com.company.processor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class DummyClass extends ProcessFunction<String, String> {
static final Logger log = LoggerFactory.getLogger(DummyClass.class);
//---inside processElement method :
log.info("Accepted Data INFO: " + value);
log.error("Accepted Data ERROR:: {}", value);
} {code}
Communication on Flink channel :
[#troubleshooting|https://apache-flink.slack.com/archives/C03G7LJTS2G/p1746771450447989?thread_ts=1746709950.589169&cid=C03G7LJTS2G]
was:
Below is the logback-console.xml being set in Flink :
{code:java}
<configuration debug="true" scan="true" scanPeriod="30 seconds">
<statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener"/>
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36}
- %msg%n</pattern>
</encoder>
</appender>
<logger name="io.company" level="INFO" additivity="false">
<appender-ref ref="CONSOLE"/>
</logger>
<logger name="com.company" level="INFO" additivity="false">
<appender-ref ref="CONSOLE"/>
</logger>
<root level="WARN">
<appender-ref ref="CONSOLE" />
</root>
</configuration> {code}
>From within a package {{com.company.processor.DummyClass.class}} I am logging
>2 statements,
1 with log.error() and other with log.info()
Expecting both to be printed, but only see the ERROR log being printed.
I have verified that the logback-console.xml is updated inside JM and TMs by
exec -it into the pods.
The dummy class
{code:java}
package com.company.processor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class DummyClass extends ProcessFunction<String, String> {
static final Logger log = LoggerFactory.getLogger(DummyClass.class);
//---inside processElement method :
log.info("Accepted Data INFO: " + value);
log.error("Accepted Data ERROR:: {}", value);
} {code}
> Logback | Not applied
> ---------------------
>
> Key: FLINK-37919
> URL: https://issues.apache.org/jira/browse/FLINK-37919
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Configuration
> Affects Versions: 1.20.1
> Reporter: Dheeraj Panangat
> Priority: Major
>
> Below is the logback-console.xml being set in Flink :
> {code:java}
> <configuration debug="true" scan="true" scanPeriod="30 seconds">
> <statusListener
> class="ch.qos.logback.core.status.OnConsoleStatusListener"/>
> <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level
> %logger{36} - %msg%n</pattern>
> </encoder>
> </appender>
> <logger name="io.company" level="INFO" additivity="false">
> <appender-ref ref="CONSOLE"/>
> </logger>
> <logger name="com.company" level="INFO" additivity="false">
> <appender-ref ref="CONSOLE"/>
> </logger>
> <root level="WARN">
> <appender-ref ref="CONSOLE" />
> </root>
> </configuration> {code}
> From within a package {{com.company.processor.DummyClass.class}} I am
> logging 2 statements,
> 1 with log.error() and other with log.info()
> Expecting both to be printed, but only see the ERROR log being printed.
> I have verified that the logback-console.xml is updated inside JM and TMs by
> exec -it into the pods.
> The dummy class
> {code:java}
> package com.company.processor;
> import org.slf4j.Logger;
> import org.slf4j.LoggerFactory;
> public class DummyClass extends ProcessFunction<String, String> {
> static final Logger log = LoggerFactory.getLogger(DummyClass.class);
> //---inside processElement method :
> log.info("Accepted Data INFO: " + value);
> log.error("Accepted Data ERROR:: {}", value);
> } {code}
> Communication on Flink channel :
> [#troubleshooting|https://apache-flink.slack.com/archives/C03G7LJTS2G/p1746771450447989?thread_ts=1746709950.589169&cid=C03G7LJTS2G]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
