[ignite] branch master updated: IGNITE-10760 Fix confusing message about system worker blocking

[agura]

This is an automated email from the ASF dual-hosted git repository.

agura pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 26698ed  IGNITE-10760 Fix confusing message about system worker 
blocking
26698ed is described below

commit 26698ed250471ff273cf1f10aac9cb35dacbce4a
Author: Mirza Aliev <alievmi...@gmail.com>
AuthorDate: Thu Nov 14 13:30:55 2019 +0300

    IGNITE-10760 Fix confusing message about system worker blocking
    
    Signed-off-by: Andrey Gura <ag...@apache.org>
---
 .../java/org/apache/ignite/internal/worker/WorkersRegistry.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/worker/WorkersRegistry.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/worker/WorkersRegistry.java
index 3d45f3f..3cf1d03 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/worker/WorkersRegistry.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/worker/WorkersRegistry.java
@@ -221,12 +221,13 @@ public class WorkersRegistry implements 
GridWorkerListener {
                     long heartbeatDelay = U.currentTimeMillis() - 
worker.heartbeatTs();
 
                     if (heartbeatDelay > sysWorkerBlockedTimeout) {
-                        GridWorker worker0 = 
registeredWorkers.get(worker.runner().getName());
+                        GridWorker worker0 = 
registeredWorkers.get(runner.getName());
 
                         if (worker0 != null && worker0 == worker) {
                             log.error("Blocked system-critical thread has been 
detected. " +
-                                "This can lead to cluster-wide undefined 
behaviour " +
-                                "[threadName=" + worker.name() + ", 
blockedFor=" + heartbeatDelay / 1000 + "s]");
+                                    "This can lead to cluster-wide undefined 
behaviour " +
+                                    "[workerName=" + worker.name() + ", 
threadName=" + runner.getName() +
+                                    ", blockedFor=" + heartbeatDelay / 1000 + 
"s]");
 
                             U.dumpThread(worker.runner(), log);