diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java index 37d1c69a1e..f6396ca17b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java @@ -1476,10 +1476,9 @@ public class GridContinuousProcessor extends GridProcessorAdapter { if (proc != null) { GridCacheAdapter cache = ctx.cache().internalCache(hnd.cacheName()); - Map> cntrs = hnd.updateCounters(); - if (cache != null && cntrs != null && !cache.isLocal() && cache.context().userCache()) - req.addUpdateCounters(ctx.localNodeId(), cntrs); + if (cache != null && !cache.isLocal() && cache.context().userCache()) + req.addUpdateCounters(ctx.localNodeId(), hnd.updateCounters()); } }