You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/02/28 14:54:50 UTC
[flink] branch release-1.7 updated: [FLINK-11787] Update Kubernetes
resources: workaround to make TM reachable from JM in Kubernetes (for Flink
1.7 only)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.7 by this push:
new 837cc07 [FLINK-11787] Update Kubernetes resources: workaround to make TM reachable from JM in Kubernetes (for Flink 1.7 only)
837cc07 is described below
commit 837cc07450d38b0e1aff11d0b8d2d75ac9ac682f
Author: Aleksey Pak <al...@ververica.com>
AuthorDate: Thu Feb 28 12:12:09 2019 +0100
[FLINK-11787] Update Kubernetes resources: workaround to make TM reachable from JM in Kubernetes (for Flink 1.7 only)
This closes #7858.
---
docs/ops/deployment/kubernetes.md | 5 +++++
flink-container/kubernetes/task-manager-deployment.yaml.template | 7 ++++++-
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/docs/ops/deployment/kubernetes.md b/docs/ops/deployment/kubernetes.md
index 5244f5e..ef0a035 100644
--- a/docs/ops/deployment/kubernetes.md
+++ b/docs/ops/deployment/kubernetes.md
@@ -147,6 +147,7 @@ spec:
image: flink:latest
args:
- taskmanager
+ - "-Dtaskmanager.host=$(K8S_POD_IP)"
ports:
- containerPort: 6121
name: data
@@ -157,6 +158,10 @@ spec:
env:
- name: JOB_MANAGER_RPC_ADDRESS
value: flink-jobmanager
+ - name: K8S_POD_IP
+ valueFrom:
+ fieldRef:
+ fieldPath: status.podIP
{% endhighlight %}
`jobmanager-service.yaml`
diff --git a/flink-container/kubernetes/task-manager-deployment.yaml.template b/flink-container/kubernetes/task-manager-deployment.yaml.template
index 55bd9a9..f75b732 100644
--- a/flink-container/kubernetes/task-manager-deployment.yaml.template
+++ b/flink-container/kubernetes/task-manager-deployment.yaml.template
@@ -31,4 +31,9 @@ spec:
containers:
- name: flink-task-manager
image: ${FLINK_IMAGE_NAME}
- args: ["task-manager", "-Djobmanager.rpc.address=flink-job-cluster"]
+ args: ["task-manager", "-Djobmanager.rpc.address=flink-job-cluster", "-Dtaskmanager.host=$(K8S_POD_IP)"]
+ env:
+ - name: K8S_POD_IP
+ valueFrom:
+ fieldRef:
+ fieldPath: status.podIP