diff --git a/salt/logstash/files/dynamic/9999_output_redis.conf b/salt/logstash/files/dynamic/9999_output_redis.conf
index 5c0e9dd09..083c2e61f 100644
--- a/salt/logstash/files/dynamic/9999_output_redis.conf
+++ b/salt/logstash/files/dynamic/9999_output_redis.conf
@@ -1,3 +1,6 @@
+{%- if salt['grains.get']('role') == 'so-master' %}
+{%- set nodetype = 'master' %}
+{%- else %}
 {%- set nodetype = salt['pillar_get']('node:node_type', 'storage') %}
 output {
 	redis {
@@ -13,3 +16,4 @@ output {
 		# batch_events => 500
 	}
 }
+{%- endif %}
\ No newline at end of file