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 2020/06/16 13:07:18 UTC
[flink] branch release-1.10 updated: [FLINK-16717][k8s] Use
headless service for rpc and blob port
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new f7a4128 [FLINK-16717][k8s] Use headless service for rpc and blob port
f7a4128 is described below
commit f7a4128634301a09c9f379ae760250ef078213f1
Author: vanderliang <va...@gmail.com>
AuthorDate: Mon Mar 23 17:36:30 2020 +0800
[FLINK-16717][k8s] Use headless service for rpc and blob port
This closes #11488.
---
flink-container/kubernetes/README.md | 4 ++++
...uster-service.yaml => job-cluster-rest-service.yaml} | 17 +++++------------
flink-container/kubernetes/job-cluster-service.yaml | 8 +-------
3 files changed, 10 insertions(+), 19 deletions(-)
diff --git a/flink-container/kubernetes/README.md b/flink-container/kubernetes/README.md
index 84b5d9c..dd7d866 100644
--- a/flink-container/kubernetes/README.md
+++ b/flink-container/kubernetes/README.md
@@ -37,6 +37,10 @@ At last, you should start the task manager deployment:
`FLINK_IMAGE_NAME=<IMAGE_NAME> FLINK_JOB_PARALLELISM=<PARALLELISM> envsubst < task-manager-deployment.yaml.template | kubectl create -f -`
+Optional service, that exposes the jobmanager rest port as public Kubernetes node’s port:
+
+`kubectl create -f job-cluster-rest-service.yaml`
+
### Additional command line arguments
You can provide the following additional command line arguments to the cluster entrypoint:
diff --git a/flink-container/kubernetes/job-cluster-service.yaml b/flink-container/kubernetes/job-cluster-rest-service.yaml
similarity index 88%
copy from flink-container/kubernetes/job-cluster-service.yaml
copy to flink-container/kubernetes/job-cluster-rest-service.yaml
index 443a027..6581880 100644
--- a/flink-container/kubernetes/job-cluster-service.yaml
+++ b/flink-container/kubernetes/job-cluster-rest-service.yaml
@@ -15,26 +15,19 @@
# See the License for the specific language governing permissions and
# limitations under the License.
################################################################################
-
+#
apiVersion: v1
kind: Service
metadata:
- name: flink-job-cluster
- labels:
- app: flink
- component: job-cluster
+ name: flink-job-cluster-rest
spec:
ports:
- - name: rpc
- port: 6123
- - name: blob
- port: 6124
+ - name: rest
+ port: 8081
+ nodePort: 30081
- name: query
port: 6125
nodePort: 30025
- - name: ui
- port: 8081
- nodePort: 30081
type: NodePort
selector:
app: flink
diff --git a/flink-container/kubernetes/job-cluster-service.yaml b/flink-container/kubernetes/job-cluster-service.yaml
index 443a027..32b4595 100644
--- a/flink-container/kubernetes/job-cluster-service.yaml
+++ b/flink-container/kubernetes/job-cluster-service.yaml
@@ -29,13 +29,7 @@ spec:
port: 6123
- name: blob
port: 6124
- - name: query
- port: 6125
- nodePort: 30025
- - name: ui
- port: 8081
- nodePort: 30081
- type: NodePort
+ clusterIP: None
selector:
app: flink
component: job-cluster