From 911e04ca8b4365bb851bf0fa6fcac991b4492fb2 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 --- .../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 8c82cf2633c..d00c3774c97 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 void corruptRecoveryLocation(Location recoveryPosition) throws IOExceptio 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 @@ protected Location recoveryCheck(DataFile dataFile) throws IOException { 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 {