Skip to content

Commit

Permalink
decrease log severity to info for common repair failures
Browse files Browse the repository at this point in the history
  • Loading branch information
varjoranta committed Aug 24, 2015
1 parent 6c413fa commit 79ac8de
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/main/java/com/spotify/reaper/service/SegmentRunner.java
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ public void run() {
}

public static void postpone(AppContext context, RepairSegment segment) {
LOG.warn("Postponing segment {}", segment.getId());
LOG.info("Postponing segment {}", segment.getId());
context.storage.updateRepairSegment(segment.with()
.state(RepairSegment.State.NOT_STARTED)
.coordinatorHost(null)
Expand Down Expand Up @@ -237,7 +237,7 @@ boolean canRepair(RepairSegment segment, String keyspace, JmxProxy coordinator)
try (JmxProxy hostProxy = context.jmxConnectionFactory.connect(hostName)) {
int pendingCompactions = hostProxy.getPendingCompactions();
if (pendingCompactions > MAX_PENDING_COMPACTIONS) {
LOG.warn("SegmentRunner declined to repair segment {} because of too many pending "
LOG.info("SegmentRunner declined to repair segment {} because of too many pending "
+ "compactions (> {}) on host \"{}\"", segmentId, MAX_PENDING_COMPACTIONS,
hostProxy.getHost());
String msg = String.format("Postponed due to pending compactions (%d)",
Expand All @@ -246,7 +246,7 @@ boolean canRepair(RepairSegment segment, String keyspace, JmxProxy coordinator)
return false;
}
if (hostProxy.isRepairRunning()) {
LOG.warn("SegmentRunner declined to repair segment {} because one of the hosts ({}) was "
LOG.info("SegmentRunner declined to repair segment {} because one of the hosts ({}) was "
+ "already involved in a repair", segmentId, hostProxy.getHost());
String msg = "Postponed due to affected hosts already doing repairs";
repairRunner.updateLastEvent(msg);
Expand Down

0 comments on commit 79ac8de

Please sign in to comment.