This is an automated email from the ASF dual-hosted git repository.

wiener pushed a commit to branch rel/0.67.0
in repository 
https://gitbox.apache.org/repos/asf/incubator-streampipes-installer.git


The following commit(s) were added to refs/heads/rel/0.67.0 by this push:
     new fc83948  [STREAMPIPES-225] add pipeline-elements-all-flink container
fc83948 is described below

commit fc839487b376973aa1ff4f51c2f6fea382137fda
Author: Patrick Wiener <[email protected]>
AuthorDate: Mon Sep 7 10:51:39 2020 +0200

    [STREAMPIPES-225] add pipeline-elements-all-flink container
---
 .../docker-compose.dev.yml                         | 21 +++-------
 .../pipeline-elements-all-flink/docker-compose.yml | 34 ++++++++-------
 compose/docker-compose.full.yml                    | 49 +---------------------
 .../processors-aggregation-flink-deployment.yaml   | 44 -------------------
 .../full/processors-aggregation-flink-service.yaml | 31 --------------
 .../full/processors-enricher-flink-deployment.yaml | 44 -------------------
 .../full/processors-filters-jvm-deployment.yaml    | 41 ------------------
 .../full/processors-filters-jvm-service.yaml       | 31 --------------
 .../full/processors-filters-siddhi-deployment.yaml | 41 ------------------
 ...processors-image-processing-jvm-deployment.yaml | 41 ------------------
 .../processors-image-processing-jvm-service.yaml   | 31 --------------
 ...cessors-pattern-detection-flink-deployment.yaml | 44 -------------------
 ...processors-pattern-detection-flink-service.yaml | 31 --------------
 .../processors-statistics-flink-deployment.yaml    | 44 -------------------
 .../full/processors-statistics-flink-service.yaml  | 31 --------------
 ...processors-transformation-flink-deployment.yaml | 44 -------------------
 .../processors-transformation-flink-service.yaml   | 31 --------------
 .../processors-transformation-jvm-deployment.yaml  | 41 ------------------
 .../processors-transformation-jvm-service.yaml     | 31 --------------
 .../full/sinks-brokers-jvm-deployment.yaml         | 41 ------------------
 .../full/sinks-databases-flink-service.yaml        | 31 --------------
 .../full/sinks-databases-jvm-deployment.yaml       | 41 ------------------
 .../full/sinks-databases-jvm-service.yaml          | 31 --------------
 .../full/sinks-internal-jvm-deployment.yaml        | 48 ---------------------
 .../full/sinks-internal-jvm-service.yaml           | 31 --------------
 .../full/sinks-notifications-jvm-deployment.yaml   | 41 ------------------
 .../full/sinks-notifications-jvm-service.yaml      | 31 --------------
 .../sources-watertank-simulator-deployment.yaml    | 41 ------------------
 .../lite/sources-watertank-simulator-service.yaml  | 31 --------------
 ...=> pipeline-elements-all-flink-deployment.yaml} | 12 +++---
 ...ml => pipeline-elements-all-flink-service.yaml} |  6 +--
 .../pipeline-elements-all-jvm-deployment.yaml      |  2 -
 .../pipeline-elements-all-jvm-service.yaml         |  2 -
 .../sources-vehicle-simulator-deployment.yaml      |  0
 .../sources-vehicle-simulator-service.yaml         |  0
 .../sources-watertank-simulator-deployment.yaml    |  2 -
 .../sources-watertank-simulator-service.yaml       |  2 -
 37 files changed, 34 insertions(+), 1064 deletions(-)

diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-service.yaml
 b/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.dev.yml
similarity index 73%
rename from 
k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-service.yaml
rename to 
cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.dev.yml
index 581bbb6..cf962bb 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-service.yaml
+++ b/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.dev.yml
@@ -13,19 +13,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sinks-brokers-jvm
-  labels:
-    name: sinks-brokers-jvm
-spec:
-  selector:
-    app: sinks-brokers-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
+version: "3.4"
+services:
+  pipeline-elements-all-flink:
+#    ports:
+#      - "8098:8090"
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-service.yaml
 b/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.yml
similarity index 69%
rename from 
k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-service.yaml
rename to cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.yml
index 766432f..cd1e772 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-service.yaml
+++ b/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.yml
@@ -13,19 +13,21 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-filters-siddhi
-  labels:
-    name: processors-filters-siddhi
-spec:
-  selector:
-    app: processors-filters-siddhi
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
+version: "3.4"
+services:
+  pipeline-elements-all-flink:
+    image: ${SP_DOCKER_REGISTRY}pipeline-elements-all-flink:${SP_VERSION}
+    depends_on:
+      - "consul"
+      - "jobmanager"
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "1m"
+        max-file: "1"
+    networks:
+      spnet:
+
+networks:
+  spnet:
+    external: true
diff --git a/compose/docker-compose.full.yml b/compose/docker-compose.full.yml
index a842d48..002653b 100644
--- a/compose/docker-compose.full.yml
+++ b/compose/docker-compose.full.yml
@@ -194,53 +194,8 @@ services:
       spnet:
 
   # Full version pipeline elements
-  processors-aggregation-flink:
-    image: "${SP_DOCKER_REGISTRY}/processors-aggregation-flink:${SP_VERSION}"
-    depends_on:
-      - consul
-      - jobmanager
-    logging: *default-logging
-    networks:
-      spnet:
-
-  processors-enricher-flink:
-    image: "${SP_DOCKER_REGISTRY}/processors-enricher-flink:${SP_VERSION}"
-    depends_on:
-      - consul
-      - jobmanager
-    logging: *default-logging
-    networks:
-      spnet:
-
-  processors-pattern-detection-flink:
-    image: 
"${SP_DOCKER_REGISTRY}/processors-pattern-detection-flink:${SP_VERSION}"
-    depends_on:
-      - consul
-      - jobmanager
-    logging: *default-logging
-    networks:
-      spnet:
-
-  processors-statistics-flink:
-    image: "${SP_DOCKER_REGISTRY}/processors-statistics-flink:${SP_VERSION}"
-    depends_on:
-      - consul
-      - jobmanager
-    logging: *default-logging
-    networks:
-      spnet:
-
-  processors-transformation-flink:
-    image: 
"${SP_DOCKER_REGISTRY}/processors-transformation-flink:${SP_VERSION}"
-    depends_on:
-      - consul
-      - jobmanager
-    logging: *default-logging
-    networks:
-      spnet:
-
-  sinks-databases-flink:
-    image: "${SP_DOCKER_REGISTRY}/sinks-databases-flink:${SP_VERSION}"
+  pipeline-elements-all-flink:
+    image: "${SP_DOCKER_REGISTRY}/pipeline-elements-all-flink:${SP_VERSION}"
     depends_on:
       - consul
       - jobmanager
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-deployment.yaml
deleted file mode 100644
index 999f9e4..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-deployment.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-aggregation-flink
-spec:
-  selector:
-    matchLabels:
-      app: processors-aggregation-flink
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-aggregation-flink
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-        - name: init-wait-jobmanager
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-aggregation-flink
-          image: {{ .Values.streampipes.registry 
}}/processors-aggregation-flink:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-service.yaml
deleted file mode 100644
index 23d36d3..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-aggregation-flink-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-aggregation-flink
-  labels:
-    name: processors-aggregation-flink
-spec:
-  selector:
-    app: processors-aggregation-flink
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-deployment.yaml
deleted file mode 100644
index 7a2e984..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-deployment.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-enricher-flink
-spec:
-  selector:
-    matchLabels:
-      app: processors-enricher-flink
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-enricher-flink
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-        - name: init-wait-jobmanager
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-enricher-flink
-          image: {{ .Values.streampipes.registry 
}}/processors-enricher-flink:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-deployment.yaml
deleted file mode 100644
index 8202a14..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-filters-jvm
-spec:
-  selector:
-    matchLabels:
-      app: processors-filters-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-filters-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-filters-jvm
-          image: {{ .Values.streampipes.registry }}/processors-filters-jvm:{{ 
.Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-service.yaml
deleted file mode 100644
index e60b518..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-filters-jvm
-  labels:
-    name: processors-filters-jvm
-spec:
-  selector:
-    app: processors-filters-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-deployment.yaml
deleted file mode 100644
index 29c5f52..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-filters-siddhi-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-filters-siddhi
-spec:
-  selector:
-    matchLabels:
-      app: processors-filters-siddhi
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-filters-siddhi
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-filters-siddhi
-          image: {{ .Values.streampipes.registry 
}}/processors-filters-siddhi:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-deployment.yaml
deleted file mode 100644
index 192cb54..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-image-processing-jvm
-spec:
-  selector:
-    matchLabels:
-      app: processors-image-processing-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-image-processing-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-image-processing-jvm
-          image: {{ .Values.streampipes.registry 
}}/processors-image-processing-jvm:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-service.yaml
deleted file mode 100644
index f57ec8e..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-image-processing-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-image-processing-jvm
-  labels:
-    name: processors-image-processing-jvm
-spec:
-  selector:
-    app: processors-image-processing-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-deployment.yaml
deleted file mode 100644
index 9733313..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-deployment.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-pattern-detection-flink
-spec:
-  selector:
-    matchLabels:
-      app: processors-pattern-detection-flink
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-pattern-detection-flink
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-        - name: init-wait-jobmanager
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-pattern-detection-flink
-          image: {{ .Values.streampipes.registry 
}}/processors-pattern-detection-flink:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-service.yaml
deleted file mode 100644
index dc0f07d..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-pattern-detection-flink-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-pattern-detection-flink
-  labels:
-    name: processors-pattern-detection-flink
-spec:
-  selector:
-    app: processors-pattern-detection-flink
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-deployment.yaml
deleted file mode 100644
index f39dab5..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-deployment.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-statistics-flink
-spec:
-  selector:
-    matchLabels:
-      app: processors-statistics-flink
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-statistics-flink
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-        - name: init-wait-jobmanager
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-statistics-flink
-          image: {{ .Values.streampipes.registry 
}}/processors-statistics-flink:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-service.yaml
deleted file mode 100644
index 7b8fb0a..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-statistics-flink-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-statistics-flink
-  labels:
-    name: processors-statistics-flink
-spec:
-  selector:
-    app: processors-statistics-flink
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-deployment.yaml
deleted file mode 100644
index 2bc9153..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-deployment.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-transformation-flink
-spec:
-  selector:
-    matchLabels:
-      app: processors-transformation-flink
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-transformation-flink
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-        - name: init-wait-jobmanager
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-transformation-flink
-          image: {{ .Values.streampipes.registry 
}}/processors-transformation-flink:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-service.yaml
deleted file mode 100644
index 0731d88..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-flink-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-transformation-flink
-  labels:
-    name: processors-transformation-flink
-spec:
-  selector:
-    app: processors-transformation-flink
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-deployment.yaml
deleted file mode 100644
index 060296d..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: processors-transformation-jvm
-spec:
-  selector:
-    matchLabels:
-      app: processors-transformation-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: processors-transformation-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: processors-transformation-jvm
-          image: {{ .Values.streampipes.registry 
}}/processors-transformation-jvm:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-service.yaml
deleted file mode 100644
index ce1f4da..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-transformation-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: processors-transformation-jvm
-  labels:
-    name: processors-transformation-jvm
-spec:
-  selector:
-    app: processors-transformation-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-deployment.yaml
deleted file mode 100644
index 0dd4b02..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-brokers-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: sinks-brokers-jvm
-spec:
-  selector:
-    matchLabels:
-      app: sinks-brokers-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: sinks-brokers-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: sinks-brokers-jvm
-          image: {{ .Values.streampipes.registry }}/sinks-brokers-jvm:{{ 
.Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-service.yaml
deleted file mode 100644
index a4a16b8..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sinks-databases-flink
-  labels:
-    name: sinks-databases-flink
-spec:
-  selector:
-    app: sinks-databases-flink
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-deployment.yaml
deleted file mode 100644
index 000d7eb..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: sinks-databases-jvm
-spec:
-  selector:
-    matchLabels:
-      app: sinks-databases-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: sinks-databases-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: sinks-databases-jvm
-          image: {{ .Values.streampipes.registry }}/sinks-databases-jvm:{{ 
.Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-service.yaml
deleted file mode 100644
index 0e687ac..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sinks-databases-jvm
-  labels:
-    name: sinks-databases-jvm
-spec:
-  selector:
-    app: sinks-databases-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-deployment.yaml
deleted file mode 100644
index 35d1935..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-deployment.yaml
+++ /dev/null
@@ -1,48 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: sinks-internal-jvm
-spec:
-  selector:
-    matchLabels:
-      app: sinks-internal-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: sinks-internal-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      volumes:
-        - name: files-pv
-          persistentVolumeClaim:
-            claimName: files-pvc            
-      containers:
-        - name: sinks-internal-jvm
-          image: {{ .Values.streampipes.registry }}/sinks-internal-jvm:{{ 
.Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-          volumeMounts:
-            - mountPath: "/spImages"
-              name: files-pv                
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-service.yaml
deleted file mode 100644
index 602f28e..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-internal-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sinks-internal-jvm
-  labels:
-    name: sinks-internal-jvm
-spec:
-  selector:
-    app: sinks-internal-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-deployment.yaml
deleted file mode 100644
index a4b4ef5..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: sinks-notifications-jvm
-spec:
-  selector:
-    matchLabels:
-      app: sinks-notifications-jvm
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: sinks-notifications-jvm
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: sinks-notifications-jvm
-          image: {{ .Values.streampipes.registry }}/sinks-notifications-jvm:{{ 
.Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-service.yaml
deleted file mode 100644
index fa5c765..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-notifications-jvm-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "full") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sinks-notifications-jvm
-  labels:
-    name: sinks-notifications-jvm
-spec:
-  selector:
-    app: sinks-notifications-jvm
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-deployment.yaml
deleted file mode 100644
index ae54a7b..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-deployment.yaml
+++ /dev/null
@@ -1,41 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "lite") }}
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: sources-watertank-simulator
-spec:
-  selector:
-    matchLabels:
-      app: sources-watertank-simulator
-  replicas: 1
-  template:
-    metadata:
-      labels:
-        app: sources-watertank-simulator
-    spec:
-      initContainers:
-        - name: init-wait-consul
-          image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
-      containers:
-        - name: sources-watertank-simulator
-          image: {{ .Values.streampipes.registry 
}}/sources-watertank-simulator:{{ .Values.streampipes.version }}
-          imagePullPolicy: {{ .Values.pullPolicy }}
-          ports:
-            - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-service.yaml
deleted file mode 100644
index 69aabc0..0000000
--- 
a/k8s/templates/extensions/pipeline-elements/lite/sources-watertank-simulator-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{{- if (eq .Values.deployment "lite") }}
-apiVersion: v1
-kind: Service
-metadata:
-  name: sources-watertank-simulator
-  labels:
-    name: sources-watertank-simulator
-spec:
-  selector:
-    app: sources-watertank-simulator
-  ports:
-    - name: main
-      protocol: TCP
-      port: 8090
-      targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-deployment.yaml
similarity index 81%
rename from 
k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-deployment.yaml
rename to 
k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-deployment.yaml
index deadb2b..2e8372f 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/sinks-databases-flink-deployment.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-deployment.yaml
@@ -17,16 +17,16 @@
 apiVersion: apps/v1
 kind: Deployment
 metadata:
-  name: sinks-databases-flink
+  name: pipeline-elements-all-flink
 spec:
   selector:
     matchLabels:
-      app: sinks-databases-flink
+      app: pipeline-elements-all-flink
   replicas: 1
   template:
     metadata:
       labels:
-        app: sinks-databases-flink
+        app: pipeline-elements-all-flink
     spec:
       initContainers:
         - name: init-wait-consul
@@ -34,10 +34,10 @@ spec:
           command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 
8600 && exit 0 || sleep 3; done; exit 1"]
         - name: init-wait-jobmanager
           image: alpine
-          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
6123 && exit 0 || sleep 3; done; exit 1"]
+          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 jobmanager 
8081 && exit 0 || sleep 3; done; exit 1"]
       containers:
-        - name: sinks-databases-flink
-          image: {{ .Values.streampipes.registry }}/sinks-databases-flink:{{ 
.Values.streampipes.version }}
+        - name: pipeline-elements-all-flink
+          image: {{ .Values.streampipes.registry 
}}/pipeline-elements-all-flink:{{ .Values.streampipes.version }}
           imagePullPolicy: {{ .Values.pullPolicy }}
           ports:
             - containerPort: 8090
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-service.yaml
similarity index 89%
rename from 
k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-service.yaml
rename to 
k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-service.yaml
index 012834e..18295df 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/processors-enricher-flink-service.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-service.yaml
@@ -17,12 +17,12 @@
 apiVersion: v1
 kind: Service
 metadata:
-  name: processors-enricher-flink
+  name: pipeline-elements-all-flink
   labels:
-    name: processors-enricher-flink
+    name: pipeline-elements-all-flink
 spec:
   selector:
-    app: processors-enricher-flink
+    app: pipeline-elements-all-flink
   ports:
     - name: main
       protocol: TCP
diff --git 
a/k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-deployment.yaml
similarity index 97%
rename from 
k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-deployment.yaml
rename to 
k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-deployment.yaml
index f9b4774..f25b980 100644
--- 
a/k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-deployment.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-deployment.yaml
@@ -13,7 +13,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "lite") }}
 apiVersion: apps/v1
 kind: Deployment
 metadata:
@@ -46,4 +45,3 @@ spec:
           volumeMounts:
             - mountPath: "/spImages"
               name: files-pv          
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-service.yaml
similarity index 95%
rename from 
k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-service.yaml
rename to 
k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-service.yaml
index 5a89df4..4072603 100644
--- 
a/k8s/templates/extensions/pipeline-elements/lite/pipeline-elements-all-jvm-service.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-jvm-service.yaml
@@ -13,7 +13,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "lite") }}
 apiVersion: v1
 kind: Service
 metadata:
@@ -28,4 +27,3 @@ spec:
       protocol: TCP
       port: 8090
       targetPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sources-vehicle-simulator-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
similarity index 100%
rename from 
k8s/templates/extensions/pipeline-elements/full/sources-vehicle-simulator-deployment.yaml
rename to 
k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sources-vehicle-simulator-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-service.yaml
similarity index 100%
rename from 
k8s/templates/extensions/pipeline-elements/full/sources-vehicle-simulator-service.yaml
rename to 
k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-service.yaml
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-deployment.yaml
 
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
similarity index 96%
rename from 
k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-deployment.yaml
rename to 
k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
index 1fd00a7..523711f 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-deployment.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
@@ -13,7 +13,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "full") }}
 apiVersion: apps/v1
 kind: Deployment
 metadata:
@@ -38,4 +37,3 @@ spec:
           imagePullPolicy: {{ .Values.pullPolicy }}
           ports:
             - containerPort: 8090
-{{- end }}
diff --git 
a/k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-service.yaml
 
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-service.yaml
similarity index 95%
rename from 
k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-service.yaml
rename to 
k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-service.yaml
index 1b0b080..32147c7 100644
--- 
a/k8s/templates/extensions/pipeline-elements/full/sources-watertank-simulator-service.yaml
+++ 
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-service.yaml
@@ -13,7 +13,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-{{- if (eq .Values.deployment "full") }}
 apiVersion: v1
 kind: Service
 metadata:
@@ -28,4 +27,3 @@ spec:
       protocol: TCP
       port: 8090
       targetPort: 8090
-{{- end }}

Reply via email to