diff --git a/salt/logstash/pipelines/config/so/0900_input_redis.conf.jinja b/salt/logstash/pipelines/config/so/0900_input_redis.conf.jinja
index 60229422b..4b108d1b6 100644
--- a/salt/logstash/pipelines/config/so/0900_input_redis.conf.jinja
+++ b/salt/logstash/pipelines/config/so/0900_input_redis.conf.jinja
@@ -1,4 +1,8 @@
+{%- if grains.role in ['so-heavynode'] %}
+{%- set MANAGER = salt['grains.get']('host') %}
+{%- else %}
 {%- set MANAGER = salt['grains.get']('master') %}
+{%- endif %}
 {%- set THREADS = salt['pillar.get']('logstash_settings:ls_input_threads', '') %}
 {% set BATCH = salt['pillar.get']('logstash_settings:ls_pipeline_batch_size', 125) %}