You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/09/14 09:56:52 UTC
[incubator-streampipes-installer] branch dev updated: [hotfix] add init wait on kafka service, fix wrong deployment name
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-installer.git
The following commit(s) were added to refs/heads/dev by this push:
new 90f7699 [hotfix] add init wait on kafka service, fix wrong deployment name
90f7699 is described below
commit 90f769930cb9e1cbe9bb5f7cefea8ae2e0e29867
Author: Patrick Wiener <wi...@fzi.de>
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