diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java index ec7752a1ba817..4aaca1d90cbed 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java @@ -141,6 +141,11 @@ public boolean taskSessionFullSupport() { return taskSesFullSupport; } + /** @return Task name. */ + public String taskName() { + return taskName; + } + /** * Write topology information. * diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java index ebcfc3ad5eef2..3c8d15c7f4687 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java @@ -641,6 +641,9 @@ else if (task != null) { } } + if (task instanceof PlatformFullTask) + taskName = ((PlatformFullTask)task).taskName(); + assert taskName != null; if (log.isDebugEnabled())