This is an automated email from the ASF dual-hosted git repository.
rpuch pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 294b6a9cf8f IGNITE-25679 Do not log harmless events on WARN in JRaft
(#6040)
294b6a9cf8f is described below
commit 294b6a9cf8f7ef39c5f57fb53d675a8520825ae7
Author: Roman Puchkovskiy <[email protected]>
AuthorDate: Sat Jun 14 14:35:46 2025 +0400
IGNITE-25679 Do not log harmless events on WARN in JRaft (#6040)
---
.../apache/ignite/internal/placementdriver/LeaseUpdater.java | 2 +-
.../main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java | 10 +++++-----
.../java/org/apache/ignite/raft/jraft/core/Replicator.java | 2 +-
.../apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java | 2 +-
.../jraft/storage/snapshot/local/LocalSnapshotStorage.java | 2 +-
5 files changed, 9 insertions(+), 9 deletions(-)
diff --git
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/LeaseUpdater.java
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/LeaseUpdater.java
index e511799e7e4..bff5bcac2aa 100644
---
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/LeaseUpdater.java
+++
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/LeaseUpdater.java
@@ -408,7 +408,7 @@ public class LeaseUpdater {
try {
Thread.sleep(UPDATE_LEASE_MS);
} catch (InterruptedException e) {
- LOG.warn("Lease updater is interrupted");
+ LOG.info("Lease updater is interrupted");
}
}
}
diff --git
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java
index 819c6840e4d..007a73231b7 100644
--- a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java
+++ b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java
@@ -2253,7 +2253,7 @@ public class NodeImpl implements Node, RaftServerService {
// Check stale term
if (request.term() < this.currTerm) {
- LOG.warn("Node {} ignore stale AppendEntriesRequest from {},
term={}, currTerm={}.", getNodeId(),
+ LOG.info("Node {} ignore stale AppendEntriesRequest from {},
term={}, currTerm={}.", getNodeId(),
request.serverId(), request.term(), this.currTerm);
AppendEntriesResponseBuilder rb =
raftOptions.getRaftMessagesFactory()
.appendEntriesResponse()
@@ -2295,7 +2295,7 @@ public class NodeImpl implements Node, RaftServerService {
if (localPrevLogTerm != prevLogTerm) {
final long lastLogIndex = this.logManager.getLastLogIndex();
- LOG.warn("Node {} reject term_unmatched AppendEntriesRequest
from {}, term={}, prevLogIndex={}, " +
+ LOG.info("Node {} reject term_unmatched AppendEntriesRequest
from {}, term={}, prevLogIndex={}, " +
"prevLogTerm={}, localPrevLogTerm={}, lastLogIndex={},
entriesSize={}.",
getNodeId(), request.serverId(), request.term(),
prevLogIndex, prevLogTerm, localPrevLogTerm,
lastLogIndex, entriesCount);
@@ -2930,7 +2930,7 @@ public class NodeImpl implements Node, RaftServerService {
this.writeLock.lock();
try {
if (this.state != State.STATE_CANDIDATE) {
- LOG.warn("Node {} received invalid RequestVoteResponse from
{}, state not in STATE_CANDIDATE but {}.",
+ LOG.info("Node {} received invalid RequestVoteResponse from
{}, state not in STATE_CANDIDATE but {}.",
getNodeId(), peerId, this.state);
return;
}
@@ -2995,7 +2995,7 @@ public class NodeImpl implements Node, RaftServerService {
this.writeLock.lock();
try {
if (this.state != State.STATE_FOLLOWER) {
- LOG.warn("Node {} received invalid PreVoteResponse from {},
state not in STATE_FOLLOWER but {}.",
+ LOG.info("Node {} received invalid PreVoteResponse from {},
state not in STATE_FOLLOWER but {}.",
getNodeId(), peerId, this.state);
return;
}
@@ -3819,7 +3819,7 @@ public class NodeImpl implements Node, RaftServerService {
this.writeLock.lock();
try {
if (!this.state.isActive()) {
- LOG.warn("Node {} ignore InstallSnapshotRequest as it is not
in active state {}.", getNodeId(),
+ LOG.info("Node {} ignore InstallSnapshotRequest as it is not
in active state {}.", getNodeId(),
this.state);
return RaftRpcFactory.DEFAULT //
.newResponse(raftOptions.getRaftMessagesFactory(),
RaftError.EINVAL,
diff --git
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/Replicator.java
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/Replicator.java
index 4537b769e51..4e76fb09df3 100644
---
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/Replicator.java
+++
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/Replicator.java
@@ -985,7 +985,7 @@ public class Replicator implements ThreadId.OnError {
r.sendEntries();
}
else {
- LOG.warn("Replicator stops sending entries [replicator={}].", id);
+ LOG.info("Replicator stops sending entries [replicator={}].", id);
id.unlock();
}
return true;
diff --git
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
index fed76d39c6d..27a0fb84f90 100644
---
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
+++
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
@@ -549,7 +549,7 @@ public class LogManagerImpl implements LogManager {
startMs = Utils.monotonicMs();
try {
final TruncateSuffixClosure tsc =
(TruncateSuffixClosure) done;
- LOG.warn(
+ LOG.info(
"Truncating log storage suffix
[groupId={}, lastIndexKept={}]",
nodeId.getGroupId(),
tsc.lastIndexKept
diff --git
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/snapshot/local/LocalSnapshotStorage.java
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/snapshot/local/LocalSnapshotStorage.java
index 7b808120a70..ee7501c9886 100644
---
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/snapshot/local/LocalSnapshotStorage.java
+++
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/snapshot/local/LocalSnapshotStorage.java
@@ -308,7 +308,7 @@ public class LocalSnapshotStorage implements
SnapshotStorage {
this.lock.unlock();
}
if (lsIndex == 0) {
- LOG.warn("No data for snapshot reader {}.", this.path);
+ LOG.info("No data for snapshot reader {}.", this.path);
return null;
}
final String snapshotPath = getSnapshotPath(lsIndex);
