(ignite-3) branch main updated: IGNITE-26197 Add configuration information into the message about critical thread being blocked (#6426)

[rp...@apache.org]

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 c0a3e9f0a0b IGNITE-26197 Add configuration information into the message about critical thread being blocked (#6426)
c0a3e9f0a0b is described below

commit c0a3e9f0a0bab231423c1727cddf16b104b0deed
Author: Roman Puchkovskiy <ro...@gmail.com>
AuthorDate: Thu Aug 14 17:30:37 2025 +0400

    IGNITE-26197 Add configuration information into the message about critical thread being blocked (#6426)
---
 .../apache/ignite/internal/worker/ItCriticalWorkerMonitoringTest.java  | 3 ++-
 .../java/org/apache/ignite/internal/worker/CriticalWorkerWatchdog.java | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/modules/workers/src/integrationTest/java/org/apache/ignite/internal/worker/ItCriticalWorkerMonitoringTest.java b/modules/workers/src/integrationTest/java/org/apache/ignite/internal/worker/ItCriticalWorkerMonitoringTest.java
index 729f6264576..a40a33d2f07 100644
--- a/modules/workers/src/integrationTest/java/org/apache/ignite/internal/worker/ItCriticalWorkerMonitoringTest.java
+++ b/modules/workers/src/integrationTest/java/org/apache/ignite/internal/worker/ItCriticalWorkerMonitoringTest.java
@@ -79,7 +79,8 @@ class ItCriticalWorkerMonitoringTest extends ClusterPerTestIntegrationTest {
     }
 
     private static String criticalThreadDetectedRegex(String threadSignature) {
-        return "A critical thread is blocked for \\d+ ms that is more than the allowed \\d+ ms, it is .+" + threadSignature + ".+";
+        return "A critical thread is blocked for \\d+ ms that is more than the allowed \\d+ ms \\(defined at "
+                + "ignite\\.system\\.criticalWorkers\\.maxAllowedLagMillis local config property\\), it is .+" + threadSignature + ".+";
     }
 
     @Test
diff --git a/modules/workers/src/main/java/org/apache/ignite/internal/worker/CriticalWorkerWatchdog.java b/modules/workers/src/main/java/org/apache/ignite/internal/worker/CriticalWorkerWatchdog.java
index ef0dcc85dfd..4ed463abcdf 100644
--- a/modules/workers/src/main/java/org/apache/ignite/internal/worker/CriticalWorkerWatchdog.java
+++ b/modules/workers/src/main/java/org/apache/ignite/internal/worker/CriticalWorkerWatchdog.java
@@ -142,7 +142,7 @@ public class CriticalWorkerWatchdog implements CriticalWorkerRegistry, IgniteCom
                         .append(delayedThreadIdsToDelays.get(threadInfo.getThreadId()))
                         .append(" ms that is more than the allowed ")
                         .append(maxAllowedLag)
-                        .append(" ms, it is ");
+                        .append(" ms (defined at ignite.system.criticalWorkers.maxAllowedLagMillis local config property), it is ");
 
                 appendThreadInfo(message, threadInfo);