Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[hotfix][docs] Fix file reference #24734

Merged
merged 1 commit into from
Apr 29, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ under the License.
$ kubectl create -f flink-configuration-configmap.yaml
$ kubectl create -f jobmanager-service.yaml
# 为集群创建 deployment
$ kubectl create -f jobmanager-session-deployment.yaml
$ kubectl create -f jobmanager-session-deployment-non-ha.yaml
$ kubectl create -f taskmanager-session-deployment.yaml
```

Expand All @@ -91,7 +91,7 @@ $ ./bin/flink run -m localhost:8081 ./examples/streaming/TopSpeedWindowing.jar
$ kubectl delete -f jobmanager-service.yaml
$ kubectl delete -f flink-configuration-configmap.yaml
$ kubectl delete -f taskmanager-session-deployment.yaml
$ kubectl delete -f jobmanager-session-deployment.yaml
$ kubectl delete -f jobmanager-session-deployment-non-ha.yaml
```

{{< top >}}
Expand All @@ -114,7 +114,7 @@ $ ./bin/flink run -m localhost:8081 ./examples/streaming/TopSpeedWindowing.jar

检查 [Application 集群资源定义](#application-cluster-resource-definitions) 并做出相应的调整:

`jobmanager-job.yaml` 中的 `args` 属性必须指定用户作业的主类。也可以参考[如何设置 JobManager 参数]({{< ref "docs/deployment/resource-providers/standalone/docker" >}}#jobmanager-additional-command-line-arguments)来了解如何将额外的 `args` 传递给 `jobmanager-job.yaml` 配置中指定的 Flink 镜像。
`jobmanager-application-non-ha.yaml` 中的 `args` 属性必须指定用户作业的主类。也可以参考[如何设置 JobManager 参数]({{< ref "docs/deployment/resource-providers/standalone/docker" >}}#jobmanager-additional-command-line-arguments)来了解如何将额外的 `args` 传递给 `jobmanager-application-non-ha.yaml` 配置中指定的 Flink 镜像。

*job artifacts* 可由以下方式提供:

Expand All @@ -125,15 +125,15 @@ $ ./bin/flink run -m localhost:8081 ./examples/streaming/TopSpeedWindowing.jar
在创建[通用集群组件](#common-cluster-resource-definitions)后,指定 [Application 集群资源定义](#application-cluster-resource-definitions)文件,执行 `kubectl` 命令来启动 Flink Application 集群:

```sh
$ kubectl create -f jobmanager-job.yaml
$ kubectl create -f jobmanager-application-non-ha.yaml
$ kubectl create -f taskmanager-job-deployment.yaml
```

要停止单个 application 集群,可以使用 `kubectl` 命令来删除相应组件以及 [通用集群资源](#common-cluster-resource-definitions)对应的组件 :

```sh
$ kubectl delete -f taskmanager-job-deployment.yaml
$ kubectl delete -f jobmanager-job.yaml
$ kubectl delete -f jobmanager-application-non-ha.yaml
```

<a name="per-job-cluster-mode"></a>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,9 +113,9 @@ A basic *Flink Application cluster* deployment in Kubernetes has three component

Check [the Application cluster specific resource definitions](#application-cluster-resource-definitions) and adjust them accordingly:

The `args` attribute in the `jobmanager-job.yaml` has to specify the main class of the user job.
The `args` attribute in the `jobmanager-application-non-ha.yaml` has to specify the main class of the user job.
See also [how to specify the JobManager arguments]({{< ref "docs/deployment/resource-providers/standalone/docker" >}}#jobmanager-additional-command-line-arguments) to understand
how to pass other `args` to the Flink image in the `jobmanager-job.yaml`.
how to pass other `args` to the Flink image in the `jobmanager-application-non-ha.yaml`.


The *job artifacts* could be provided by these way:
Expand All @@ -129,7 +129,7 @@ The *job artifacts* could be provided by these way:
After creating [the common cluster components](#common-cluster-resource-definitions), use [the Application cluster specific resource definitions](#application-cluster-resource-definitions) to launch the cluster with the `kubectl` command:

```sh
$ kubectl create -f jobmanager-job.yaml
caicancai marked this conversation as resolved.
Show resolved Hide resolved
$ kubectl create -f jobmanager-application-non-ha.yaml
$ kubectl create -f taskmanager-job-deployment.yaml
```

Expand All @@ -138,7 +138,7 @@ with the `kubectl` command:

```sh
$ kubectl delete -f taskmanager-job-deployment.yaml
$ kubectl delete -f jobmanager-job.yaml
$ kubectl delete -f jobmanager-application-non-ha.yaml
```

### Session Mode
Expand Down