Dheeraj Panangat created FLINK-37919:
----------------------------------------

             Summary: 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


Below is the logback-console.xml being set in Flink :
root@raw-data-sink-taskmanager-1-1:/opt/flink/conf# ls -ltr
total 0
lrwxrwxrwx 1 root root 26 May  8 11:12 logback-console.xml -> 
..data/logback-console.xml
lrwxrwxrwx 1 root root 22 May  8 11:12 flink-conf.yaml -> ..data/flink-conf.yaml
root@raw-data-sink-taskmanager-1-1:/opt/flink/conf# cat logback-console.xml
<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>
 
>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}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to