From 8daf6f503e45281b19324fa9bb240b77a10d2806 Mon Sep 17 00:00:00 2001 From: Torsten Mielke Date: Fri, 4 Dec 2015 09:39:03 +0100 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-6071 - Log info about corrupted journal records at WARN level (cherry picked from commit 66c348b1b85e341ed508b9c10028c037a226dfb6) --- .../apache/activemq/store/kahadb/disk/journal/Journal.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java index 8c82cf2633..d00c3774c9 100644 --- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java +++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java @@ -63,7 +63,7 @@ public class Journal { try { int nextOffset = findNextBatchRecord(reader, recoveryPosition.getOffset() + 1); Sequence sequence = new Sequence(recoveryPosition.getOffset(), nextOffset >= 0 ? nextOffset - 1 : dataFile.getLength() - 1); - LOG.info("Corrupt journal records found in '" + dataFile.getFile() + "' between offsets: " + sequence); + LOG.warn("Corrupt journal records found in '" + dataFile.getFile() + "' between offsets: " + sequence); // skip corruption on getNextLocation recoveryPosition.setOffset((int) sequence.getLast() + 1); @@ -332,7 +332,7 @@ public class Journal { int nextOffset = findNextBatchRecord(reader, location.getOffset()+1); if( nextOffset >=0 ) { Sequence sequence = new Sequence(location.getOffset(), nextOffset - 1); - LOG.info("Corrupt journal records found in '"+dataFile.getFile()+"' between offsets: "+sequence); + LOG.warn("Corrupt journal records found in '" + dataFile.getFile() + "' between offsets: " + sequence); dataFile.corruptedBlocks.add(sequence); location.setOffset(nextOffset); } else {