1.ds 調用flink 的使用

官方文檔連接 ：https://dolphinscheduler.apache.org/zh-cn/docs/latest/user_doc/quick-start.html

2. 首先可以創建隊列 作為程序調用的時候作為隊列使用， 創建后不能刪除。

3. 創建租戶

1.租戶對應的是linux 用戶, 用戶worker 提交作業所使用的的用戶， 如果linux 沒有這個用戶， worker 會在執行腳本的時候創建這個用戶 2.租戶和租戶編碼都是唯一不能重復，好比一個人有名字有身份證號。 3. 創建玩租戶會在hdfs 對應的目錄上有相關的文件夾。

4. 創建用戶：

5. 創建token令牌

6. 給創建的用戶授權

7. 用剛才創建的用戶登錄

http://192.168.1.163:12345/dolphinscheduler/ui/#/monitor/servers/master

8. 資源的上傳

9 創建工作流

10 執行結果：

日志結果

總結日志 調用flink 的時候需要配置環境變量 ， 可能安裝的路徑不同可以看日志看到，并且每個workder 都需要添加環境變量
目錄

vi /ds/conf/env/dolphinscheduler_env.sh # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. #export HADOOP_HOME=/usr/hdp/current/hadoop-client export HADOOP_CONF_DIR=etc/hadoop/conf #export SPARK_HOME1=/opt/soft/spark1 export SPARK_HOME2=/opt/module/spark-2.4.3-bin-hadoop2.7/bin export PYTHON_HOME=/usr/bin/python export JAVA_HOME=/opt/module/jdk1.8.0_231 export HIVE_HOME=/usr/hdp/current/hive-client #export FLINK_HOME=/opt/soft/flink #export DATAX_HOME=/opt/soft/datax/bin/datax.py export FLINK_HOME=/opt/module/flink-1.12.4#export PATH=$HADOOP_HOME/bin:$SPARK_HOME1/bin:$SPARK_HOME2/bin:$PYTHON_HOME:$JAVA_HOME/bin:$HIVE_HOME/bin:$PATH:$FLINK_HOME/bin:$DATAX_HOME:$PATH export PATH=$HADOOP_HOME/bin:$SPARK_HOME2/bin:$PYTHON_HOME:$JAVA_HOME/bin:$HIVE_HOME/bin:$PATH:$FLINK_HOME/bin

以上需要主要的。

——————————————————————————————————————————————————————————

1. dsAPI調用說明

要用到token

head 里面需要添加的值：

keyvalue

Content-Type	application/json
token	8ecf2318b3a5369a20f73372655503fe

2. 如下圖

2. 創建項目

2.1 創建項目的源碼

3. 查詢token

總結

以上是生活随笔為你收集整理的DolphinScheduler 调用flink以及api的 使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。