Skip to content

Commit 8207b24

Browse files
committed
IGNITE-25793 Add missing logs for single message errors
1 parent 2f79b67 commit 8207b24

2 files changed

Lines changed: 7 additions & 3 deletions

File tree

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1314,8 +1314,11 @@ private void sendAllPartitions(
13141314

13151315
cctx.io().sendNoRetry(node, m, SYSTEM_POOL);
13161316
}
1317-
catch (ClusterTopologyCheckedException e) {
1318-
log.warning("Failed to send full partitions [nodeId=" + node.id() + ", topVer=" + msgTopVer + ']', e);
1317+
catch (ClusterTopologyCheckedException ignore) {
1318+
if (log.isDebugEnabled()) {
1319+
log.debug("Failed to send partition update to node because it left grid (will ignore) " +
1320+
"[node=" + node.id() + ", msg=" + m + ']');
1321+
}
13191322
}
13201323
catch (IgniteCheckedException e) {
13211324
failedNodes.add(node);

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4352,7 +4352,8 @@ private void sendAllPartitionsToNode(FinishState finishState, GridDhtPartitionsS
43524352
}
43534353
}
43544354
catch (ClusterTopologyCheckedException e) {
4355-
log.warning("Failed to send partitions [nodeId=" + node.id() + ", exchId=" + exchId + ']', e);
4355+
if (log.isDebugEnabled())
4356+
log.debug("Failed to send partitions, node failed: " + node);
43564357
}
43574358
catch (IgniteCheckedException e) {
43584359
U.error(log, "Failed to send partitions [node=" + node + ']', e);

0 commit comments

Comments
 (0)