Committed by
Gerrit Code Review
Lower log level to debug for errors that are expected during normal shutdown phase
Change-Id: I049f8ad33812ee3fcc50382b648876c6f1ba2bbd
Showing
1 changed file
with
4 additions
and
4 deletions
| ... | @@ -546,7 +546,7 @@ public class DistributedLeadershipManager implements LeadershipService { | ... | @@ -546,7 +546,7 @@ public class DistributedLeadershipManager implements LeadershipService { |
| 546 | new Leadership(path, nodeId, epoch, creationTime))); | 546 | new Leadership(path, nodeId, epoch, creationTime))); |
| 547 | } | 547 | } |
| 548 | } catch (Exception e) { | 548 | } catch (Exception e) { |
| 549 | - log.warn("Failed to purge stale lock held by {} for {}", nodeId, path, e); | 549 | + log.debug("Failed to purge stale lock held by {} for {}", nodeId, path, e); |
| 550 | rerunPurge.set(true); | 550 | rerunPurge.set(true); |
| 551 | } | 551 | } |
| 552 | }); | 552 | }); |
| ... | @@ -579,19 +579,19 @@ public class DistributedLeadershipManager implements LeadershipService { | ... | @@ -579,19 +579,19 @@ public class DistributedLeadershipManager implements LeadershipService { |
| 579 | updatedCandidates.creationTime()))); | 579 | updatedCandidates.creationTime()))); |
| 580 | } | 580 | } |
| 581 | } catch (Exception e) { | 581 | } catch (Exception e) { |
| 582 | - log.warn("Failed to evict inactive candidates {} from " | 582 | + log.debug("Failed to evict inactive candidates {} from " |
| 583 | + "candidate list for {}", removedCandidates, path, e); | 583 | + "candidate list for {}", removedCandidates, path, e); |
| 584 | rerunPurge.set(true); | 584 | rerunPurge.set(true); |
| 585 | } | 585 | } |
| 586 | } | 586 | } |
| 587 | }); | 587 | }); |
| 588 | } catch (Exception e) { | 588 | } catch (Exception e) { |
| 589 | - log.warn("Failure purging state leadership.", e); | 589 | + log.debug("Failure purging state leadership.", e); |
| 590 | rerunPurge.set(true); | 590 | rerunPurge.set(true); |
| 591 | } | 591 | } |
| 592 | 592 | ||
| 593 | if (rerunPurge.get()) { | 593 | if (rerunPurge.get()) { |
| 594 | - log.info("Rescheduling stale leadership purge due to errors encountered in previous run"); | 594 | + log.debug("Rescheduling stale leadership purge due to errors encountered in previous run"); |
| 595 | scheduleStaleLeadershipPurge(DELAY_BETWEEN_STALE_LEADERSHIP_PURGE_ATTEMPTS_SEC); | 595 | scheduleStaleLeadershipPurge(DELAY_BETWEEN_STALE_LEADERSHIP_PURGE_ATTEMPTS_SEC); |
| 596 | } | 596 | } |
| 597 | } | 597 | } | ... | ... |
-
Please register or login to post a comment