diff --git a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/agent/collector/AbstractCollector.java b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/agent/collector/AbstractCollector.java
index de0d27ed8c7..4fb939fcb27 100644
--- a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/agent/collector/AbstractCollector.java
+++ b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/agent/collector/AbstractCollector.java
@@ -69,7 +69,7 @@ public abstract class AbstractCollector<T> extends AbstractLifecycleComponent<T>
     }
 
     protected boolean isLocalNodeMaster() {
-        return clusterService.state().nodes().localNodeMaster();
+        return clusterService.state().nodes().isLocalNodeElectedMaster();
     }
 
     @Override