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 <[email protected]>
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
