Update cluster.py to fix the bug that etcd selector could not work
@@ -747,7 +747,8 @@ class KubernetesClusterLauncher(Launcher):
listen_peer_service_port=self._etcd_listening_peer_port,
listen_client_service_port=self._etcd_listening_client_port,
)
-
+ if self._etcd_pod_node_selector:
+ etcd_builder.add_etcd_pod_node_selector(self._etcd_pod_node_selector)
pods, services = etcd_builder.build()
for svc in services:
self._resource_object.append(
