From 78d6e22efb7b3f8df15c18dcd061fd6b7dfa629e Mon Sep 17 00:00:00 2001 From: iutx Date: Thu, 28 Apr 2022 14:05:01 +0800 Subject: [PATCH] fix: update deployment yaml --- docs/content/docs/deployment/overview.md | 14 +++++++++----- .../apache/flink/statefun/sdk/java/TypeName.java | 2 +- 2 files changed, 10 insertions(+), 6 deletions(-) diff --git a/docs/content/docs/deployment/overview.md b/docs/content/docs/deployment/overview.md index e5e1dd4f4..044a750e8 100644 --- a/docs/content/docs/deployment/overview.md +++ b/docs/content/docs/deployment/overview.md @@ -61,15 +61,15 @@ $ kubectl create -f flink-config.yaml $ kubectl create -f jobmanager-service.yaml # Deploy the StateFun runtime -$ kubectl create -f jobmanager-job.yaml -$ kubectl create -f taskmanager-job-deployment-yaml +$ kubectl create -f jobmanager-application.yaml +$ kubectl create -f taskmanager-job-deployment.yaml ``` To terminate the cluster, simply delete the deployments. ```bash -$ kubectl delete -f taskmanager-job-deployment-yaml -$ kubectl delete -f jobmanager-job.yaml +$ kubectl delete -f taskmanager-job-deployment.yaml +$ kubectl delete -f jobmanager-application.yaml $ kubectl delete -f jobmanager-service.yaml $ kubectl delete -f flink-config.yaml $ kubectl delete -f application-module.yaml @@ -113,6 +113,7 @@ apiVersion: v1 kind: ConfigMap metadata: name: flink-config + namespace: statefun labels: app: statefun data: @@ -174,6 +175,7 @@ apiVersion: v1 kind: Service metadata: name: flink-jobmanager + namespace: statefun spec: type: ClusterIP ports: @@ -197,6 +199,7 @@ apiVersion: v1 kind: Service metadata: name: statefun-jobmanager-rest + namespace: statefun spec: type: NodePort ports: @@ -216,12 +219,13 @@ apiVersion: apps/v1 kind: Deployment metadata: name: statefun-jobmanager + namespace: statefun spec: replicas: 1 selector: matchLabels: app: statefun - component: jobmanager + component: master template: metadata: labels: diff --git a/statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java b/statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java index 064b254df..de97604d3 100644 --- a/statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java +++ b/statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java @@ -70,7 +70,7 @@ public static TypeName typeNameFromString(String typeNameString) { /** * Creates a {@link TypeName}. * - * @param namespace the function type's namepsace. + * @param namespace the function type's namespace. * @param type the function type's name. */ private TypeName(String namespace, String type) {