diff --git a/server/src/main/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollector.java b/server/src/main/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollector.java index 379dc11a9943c..d5c7b829da428 100644 --- a/server/src/main/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollector.java +++ b/server/src/main/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollector.java @@ -35,7 +35,7 @@ public Releasable start(ClusterState clusterState, Iterable broad if (shouldRun.getAndSet(false)) { startElection.run(); } - }, heartbeat -> logger.info("skip election since there is a recent heartbeat({}) from the leader", heartbeat)); + }, heartbeat -> logger.info("skipping election since there is a recent heartbeat({}) from the leader", heartbeat)); return () -> shouldRun.set(false); } diff --git a/server/src/test/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollectorTests.java b/server/src/test/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollectorTests.java index 574f8ef231abe..f0b6d62ef9767 100644 --- a/server/src/test/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollectorTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/coordination/stateless/AtomicRegisterPreVoteCollectorTests.java @@ -92,10 +92,10 @@ public void testLogSkippedElectionIfRecentLeaderHeartbeat() throws Exception { Loggers.addAppender(logger, appender); appender.addExpectation( new MockLogAppender.SeenEventExpectation( - "warning emitted when skipping prevoting", + "log emitted when skipping election", AtomicRegisterPreVoteCollector.class.getCanonicalName(), Level.INFO, - "skip election since there is a recent heartbeat*" + "skipping election since there is a recent heartbeat*" ) ); final var fakeClock = new AtomicLong();