Flink call docs is only teld users how to use flink task in dolphinscheduler and it should be including in task/flink3.1.0-release
@ -1,123 +0,0 @@
|
||||
# Flink Calls Operating Steps |
||||
|
||||
## Create a Queue |
||||
|
||||
1. Log in to the scheduling system, click `Security`, then click `Queue manage` on the left, and click `Create queue` to create a queue. |
||||
2. Fill in the name and value of the queue, and click "Submit" |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_queue.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Create a Tenant |
||||
|
||||
``` |
||||
1. The tenant corresponds to a Linux user, which the user worker uses to submit jobs. If the Linux OS environment does not have this user, the worker will create this user when executing the script. |
||||
2. Both the tenant and the tenant code are unique and cannot be repeated, just like a person only has one name and one ID number. |
||||
3. After creating a tenant, there will be a folder in the HDFS relevant directory. |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_tenant.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Create a User |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_user.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Create a Token |
||||
|
||||
1. Log in to the scheduling system, click `Security`, then click `Token manage` on the left, and click `Create token` to create a token. |
||||
|
||||
<p align="center"> |
||||
<img src="/img/token-management-en.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
2. Select the `Expiration time` (token validity time), select `User` (choose the specified user to perform the API operation), click "Generate token", copy the `Token` string, and click "Submit". |
||||
|
||||
<p align="center"> |
||||
<img src="/img/create-token-en1.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Token Usage |
||||
|
||||
1. Open the API documentation page |
||||
|
||||
> Address:http://{api server ip}:12345/dolphinscheduler/doc.html?language=en_US&lang=en |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api-documentation-en.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
2. Select a test API, the API selected for this test is `queryAllProjectList` |
||||
|
||||
> projects/query-project-list |
||||
|
||||
3. Open `Postman`, fill in the API address, and enter the `Token` in `Headers`, and then send the request to view the result: |
||||
|
||||
``` |
||||
token: The Token just generated |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/test-api.png" width="80%" /> |
||||
</p> |
||||
|
||||
## User Authorization |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/user_authorization.png" width="80%" /> |
||||
</p> |
||||
|
||||
## User Login |
||||
|
||||
``` |
||||
http://192.168.1.163:12345/dolphinscheduler/ui/#/monitor/servers/master |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/user_login.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Upload the Resource |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/upload_resource.png" width="80%" /> |
||||
</p> |
||||
|
||||
## Create a Workflow |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow1.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow2.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow3.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow4.png" width="80%" /> |
||||
</p> |
||||
|
||||
## View the Execution Result |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/execution_result.png" width="80%" /> |
||||
</p> |
||||
|
||||
## View Log |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/log.png" width="80%" /> |
||||
</p> |
@ -1,150 +0,0 @@
|
||||
# 调用 flink 操作步骤 |
||||
|
||||
### 创建队列 |
||||
|
||||
1. 登录调度系统,点击 "安全中心",再点击左侧的 "队列管理",点击 "队列管理" 创建队列 |
||||
2. 填写队列名称和队列值,然后点击 "提交" |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_queue.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 创建租户 |
||||
|
||||
``` |
||||
1.租户对应的是 linux 用户, 用户 worker 提交作业所使用的的用户, 如果 linux 没有这个用户, worker 会在执行脚本的时候创建这个用户 |
||||
2.租户和租户编码都是唯一不能重复,好比一个人有名字有身份证号。 |
||||
3.创建完租户会在 hdfs 对应的目录上有相关的文件夹。 |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_tenant.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 创建用户 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_user.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 创建 Token |
||||
|
||||
1. 登录调度系统,点击 "安全中心",再点击左侧的 "令牌管理",点击 "令牌管理" 创建令牌 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/token-management.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
2. 选择 "失效时间" (Token有效期),选择 "用户" (以指定的用户执行接口操作),点击 "生成令牌" ,拷贝 Token 字符串,然后点击 "提交" |
||||
|
||||
<p align="center"> |
||||
<img src="/img/create-token.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
### 使用 Token |
||||
|
||||
1. 打开 API文档页面 |
||||
|
||||
> 地址:http://{api server ip}:12345/dolphinscheduler/doc.html?language=zh_CN&lang=cn |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api-documentation.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
2. 选一个测试的接口,本次测试选取的接口是:查询所有项目 |
||||
|
||||
> projects/query-project-list |
||||
|
||||
3. 打开 Postman,填写接口地址,并在 Headers 中填写 Token,发送请求后即可查看结果 |
||||
|
||||
``` |
||||
token: 刚刚生成的 Token |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/test-api.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 用户授权 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/user_authorization.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
### 用户登录 |
||||
|
||||
``` |
||||
http://192.168.1.163:12345/dolphinscheduler/ui/#/monitor/servers/master |
||||
``` |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/user_login.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 资源上传 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/upload_resource.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 创建工作流 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow1.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow2.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow3.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/create_workflow4.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 查看执行结果 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/execution_result.png" width="80%" /> |
||||
</p> |
||||
|
||||
|
||||
|
||||
|
||||
### 查看日志结果 |
||||
|
||||
<p align="center"> |
||||
<img src="/img/api/log.png" width="80%" /> |
||||
</p> |
||||
|
Before Width: | Height: | Size: 75 KiB |
Before Width: | Height: | Size: 60 KiB |
Before Width: | Height: | Size: 72 KiB |
Before Width: | Height: | Size: 81 KiB |
Before Width: | Height: | Size: 91 KiB |
Before Width: | Height: | Size: 54 KiB |
Before Width: | Height: | Size: 94 KiB |
Before Width: | Height: | Size: 209 KiB |
Before Width: | Height: | Size: 68 KiB |
Before Width: | Height: | Size: 73 KiB |
Before Width: | Height: | Size: 151 KiB |
Before Width: | Height: | Size: 67 KiB |
Before Width: | Height: | Size: 38 KiB |
Before Width: | Height: | Size: 181 KiB |
Before Width: | Height: | Size: 8.6 KiB |
Before Width: | Height: | Size: 7.5 KiB |
Before Width: | Height: | Size: 39 KiB |
Before Width: | Height: | Size: 34 KiB |
Before Width: | Height: | Size: 34 KiB |