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 ea4f5bf [hotfix] add init wait on kafka service, fix wrong deployment
name
ea4f5bf is described below
commit ea4f5bf9d3603751bfe0798db75aa74958ea93d4
Author: Patrick Wiener <[email protected]>
AuthorDate: Mon Sep 14 11:55:55 2020 +0200
[hotfix] add init wait on kafka service, fix wrong deployment name
---
.../extensions/connect-adapters/connect-worker-deployment.yaml | 3 +++
.../pipeline-elements/sources-vehicle-simulator-deployment.yaml | 3 +++
.../pipeline-elements/sources-watertank-simulator-deployment.yaml | 6 +++---
3 files changed, 9 insertions(+), 3 deletions(-)
diff --git
a/k8s/templates/extensions/connect-adapters/connect-worker-deployment.yaml
b/k8s/templates/extensions/connect-adapters/connect-worker-deployment.yaml
index 319f5e9..b67731e 100644
--- a/k8s/templates/extensions/connect-adapters/connect-worker-deployment.yaml
+++ b/k8s/templates/extensions/connect-adapters/connect-worker-deployment.yaml
@@ -37,6 +37,9 @@ spec:
- name: init-wait-connect-worker
image: alpine
command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1
connect-master 8099 && exit 0 || sleep 3; done; exit 1"]
+ - name: init-wait-kafka
+ image: alpine
+ command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 kafka 9092
&& exit 0 || sleep 3; done; exit 1"]
containers:
- name: connect-worker
image: {{ .Values.streampipes.registry }}/connect-worker:{{
.Values.streampipes.version }}
diff --git
a/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
b/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
index da4f822..acf6412 100644
---
a/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
+++
b/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
@@ -32,6 +32,9 @@ spec:
- 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-kafka
+ image: alpine
+ command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 kafka 9092
&& exit 0 || sleep 3; done; exit 1"]
containers:
- name: sources-vehicle-simulator
image: {{ .Values.streampipes.registry
}}/sources-vehicle-simulator:{{ .Values.streampipes.version }}
diff --git
a/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
index 523711f..716b269 100644
---
a/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
+++
b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
@@ -16,16 +16,16 @@
apiVersion: apps/v1
kind: Deployment
metadata:
- name: pipeline-elements-all-jvm
+ name: sources-watertank-simulator
spec:
selector:
matchLabels:
- app: pipeline-elements-all-jvm
+ app: sources-watertank-simulator
replicas: 1
template:
metadata:
labels:
- app: pipeline-elements-all-jvm
+ app: sources-watertank-simulator
spec:
initContainers:
- name: init-wait-consul