github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

fix pqrepair log4j setting (#13726) (#13768)

Browse source 
added logger for pqrepair to print log in console
Fixed: #13725
This commit is contained in:
kaisecheng 2022-02-15 16:03:16 +00:00 • committed by GitHub
parent 5197b340aa
commit cddcf18ca3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
logstash-core/src/main/java/org/logstash/ackedqueue/PqRepair.java
View file

@ -63,6 +63,8 @@ public final class PqRepair {
);
}
LOGGER.info("Start repairing queue dir: {}", path.toString());
deleteTempCheckpoint(path);
final Map<Integer, Path> pageFiles = new HashMap<>();
@ -88,6 +90,8 @@ public final class PqRepair {
fixMissingPages(pageFiles, checkpointFiles);
fixZeroSizePages(pageFiles, checkpointFiles);
fixMissingCheckpoints(pageFiles, checkpointFiles);
LOGGER.info("Repair is done");
}
private static void deleteTempCheckpoint(final Path root) throws IOException {

3
logstash-core/src/main/resources/log4j2.properties
View file

@ -9,3 +9,6 @@ appender.console.layout.pattern = [%-5level] %d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %c
rootLogger.level = error
rootLogger.appenderRefs = stdout
rootLogger.appenderRef.stdout.ref = STDOUT
logger.pqrepair.name = org.logstash.ackedqueue.PqRepair
logger.pqrepair.level = info

11
logstash-core/src/test/resources/log4j2.properties Normal file
View file

@ -0,0 +1,11 @@
name=default
appenders = console
appender.console.type = Console
appender.console.name = STDOUT
appender.console.layout.type = PatternLayout
appender.console.layout.pattern = [%-5level] %d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %c{1} - %msg%n
rootLogger.level = info
rootLogger.appenderRefs = stdout
rootLogger.appenderRef.stdout.ref = STDOUT