Skip to content

Commit fd30540

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

3 files changed

Lines changed: 10 additions & 7 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);

modules/core/src/main/java/org/apache/ignite/internal/util/distributed/DistributedProcess.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -306,10 +306,9 @@ private void sendSingleMessage(Process p) {
306306
}
307307
catch (ClusterTopologyCheckedException e) {
308308
// The coordinator has failed. The single message will be sent when a new coordinator initialized.
309-
if (log.isDebugEnabled()) {
310-
log.debug("Failed to send a single message to coordinator: [crdId=" + crdId +
311-
", processId=" + p.id + ", error=" + e.getMessage() + ']');
312-
}
309+
log.warning("Failed to send a single message to coordinator: [crdId=" + crdId +
310+
", processId=" + p.id + ", error=" + e.getMessage() + ']');
311+
313312
}
314313
catch (IgniteCheckedException e) {
315314
log.error("Unable to send message to coordinator.", e);

0 commit comments

Comments
 (0)