diff --git a/pillar/logstash/manager.sls b/pillar/logstash/manager.sls
index fc0788824..00d82f86a 100644
--- a/pillar/logstash/manager.sls
+++ b/pillar/logstash/manager.sls
@@ -1,4 +1,3 @@
-{%- set PIPELINE = salt['pillar.get']('global:pipeline', 'redis') %}
 logstash:
   pipelines:
     manager:
diff --git a/pillar/logstash/receiver.sls b/pillar/logstash/receiver.sls
index fc0788824..09c2549e6 100644
--- a/pillar/logstash/receiver.sls
+++ b/pillar/logstash/receiver.sls
@@ -1,7 +1,6 @@
-{%- set PIPELINE = salt['pillar.get']('global:pipeline', 'redis') %}
 logstash:
   pipelines:
-    manager:
+    receiver:
       config:
         - so/0009_input_beats.conf      
         - so/0010_input_hhbeats.conf
diff --git a/pillar/logstash/search.sls b/pillar/logstash/search.sls
index a0ddf946e..917657e1f 100644
--- a/pillar/logstash/search.sls
+++ b/pillar/logstash/search.sls
@@ -1,4 +1,3 @@
-{%- set PIPELINE = salt['pillar.get']('global:pipeline', 'minio') %}
 logstash:
   pipelines:
     search: