Quellcode durchsuchen

Fixes #7 - HA Zookeeper doesn't work when using depend chart (#9)

Cory Kennedy-Darby vor 5 Jahren
Ursprung
Commit
183731147d
2 geänderte Dateien mit 3 neuen und 2 gelöschten Zeilen
  1. 1 1
      flink/templates/_flink_config.tpl
  2. 2 1
      flink/values.yaml

+ 1 - 1
flink/templates/_flink_config.tpl

@@ -42,7 +42,7 @@ provide jobmanager.rpc.address to Taskmanagers
     {{- end }}
     {{- if .Values.jobmanager.highAvailability.enabled }}
     high-availability: zookeeper
-    high-availability.zookeeper.quorum: {{ .Values.jobmanager.highAvailability.zookeeperConnect }}
+    high-availability.zookeeper.quorum: {{ tpl .Values.jobmanager.highAvailability.zookeeperConnect . }}
     high-availability.zookeeper.path.root: {{ .Values.jobmanager.highAvailability.zookeeperRootpath }}
     high-availability.cluster-id: {{ .Values.jobmanager.highAvailability.clusterId }}
     high-availability.storageDir: {{ .Values.jobmanager.highAvailability.storageDir }}

+ 2 - 1
flink/values.yaml

@@ -79,7 +79,7 @@ jobmanager:
   highAvailability:
     # enabled also will enable zookeeper Dependency
     enabled: false
-    zookeeperConnect: zookeeper:2181
+    zookeeperConnect: "{{ .Release.Name }}-zookeeper:{{ .Values.zookeeper.env.ZOO_PORT }}"
     zookeeperRootPath: /flink
     clusterId: /flink
     # storageDir for Jobmanagers. DFS expected.
@@ -262,6 +262,7 @@ zookeeper:
   replicaCount: 3
   env:
     ZK_HEAP_SIZE: "1G"
+    ZOO_PORT: 2181
   resources:
     limits:
       cpu: 400m