This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 760ff5f Automated deployment: c70af8fcf73d711099b2c547e08559f51ac65c8a
760ff5f is described below
commit 760ff5f58ef0a1ee809f66ae364c99024a4f684f
Author: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Mar 10 08:49:05 2022 +0000
Automated deployment: c70af8fcf73d711099b2c547e08559f51ac65c8a
---
en-us/docs/dev/user_doc/guide/task/flink.html | 7 +++++--
en-us/docs/dev/user_doc/guide/task/flink.json | 2 +-
en-us/docs/dev/user_doc/guide/task/map-reduce.html | 9 ++++++---
en-us/docs/dev/user_doc/guide/task/map-reduce.json | 2 +-
en-us/docs/dev/user_doc/guide/task/spark.html | 7 +++++--
en-us/docs/dev/user_doc/guide/task/spark.json | 2 +-
img/tasks/demo/flink_task01.png | Bin 0 -> 114851 bytes
img/tasks/demo/flink_task02.png | Bin 0 -> 206300 bytes
img/tasks/demo/mr_task01.png | Bin 0 -> 114195 bytes
img/tasks/demo/mr_task02.png | Bin 0 -> 192182 bytes
img/tasks/demo/spark_task01.png | Bin 0 -> 112749 bytes
img/tasks/demo/spark_task02.png | Bin 0 -> 208530 bytes
img/tasks/demo/upload_jar.png | Bin 0 -> 78624 bytes
zh-cn/docs/dev/user_doc/guide/task/flink.html | 7 +++++--
zh-cn/docs/dev/user_doc/guide/task/flink.json | 2 +-
zh-cn/docs/dev/user_doc/guide/task/map-reduce.html | 7 +++++--
zh-cn/docs/dev/user_doc/guide/task/map-reduce.json | 2 +-
zh-cn/docs/dev/user_doc/guide/task/spark.html | 7 +++++--
zh-cn/docs/dev/user_doc/guide/task/spark.json | 2 +-
19 files changed, 37 insertions(+), 19 deletions(-)
diff --git a/en-us/docs/dev/user_doc/guide/task/flink.html
b/en-us/docs/dev/user_doc/guide/task/flink.html
index 2944ab9..9259c85 100644
--- a/en-us/docs/dev/user_doc/guide/task/flink.html
+++ b/en-us/docs/dev/user_doc/guide/task/flink.html
@@ -52,13 +52,16 @@
<h2>Task Example</h2>
<h3>Execute the WordCount Program</h3>
<p>This is a common introductory case in the Big Data ecosystem, which often
applied to computational frameworks such as MapReduce, Flink and Spark. The
main purpose is to count the number of identical words in the input text.
(Flink's releases come with this example job)</p>
+<h4>Configure the flink environment in DolphinScheduler</h4>
+<p>If you are using the flink task type in a production environment, it is
necessary to configure the required environment first. The configuration file
is as follows:
<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>.</p>
+<p><img src="/img/tasks/demo/flink_task01.png" alt="demo-flink-simple"></p>
<h4>Upload the Main Package</h4>
<p>When using the Flink task node, you will need to use the Resource Centre to
upload the jar package for the executable. Refer to the <a
href="../resource.md">resource center</a>.</p>
<p>After configuring the Resource Centre, you can upload the required target
files directly using drag and drop.</p>
-<p><img src="/img/tasks/demo/upload_flink.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>Configure Flink Nodes</h4>
<p>Simply configure the required content according to the parameter
descriptions above.</p>
-<p><img src="/img/tasks/demo/flink_task.png" alt="demo-flink-simple"></p>
+<p><img src="/img/tasks/demo/flink_task02.png" alt="demo-flink-simple"></p>
<h2>Notice</h2>
<p>JAVA and Scala are only used for identification, there is no difference, if
it is Flink developed by Python, there is no class of the main function, the
others are the same.</p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>About us</h3><h4>Do you need feedback? Please
contact us through the following ways.</h4></div><div
class="contact-container"><ul><li><a
href="/en-us/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>Email List</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png [...]
diff --git a/en-us/docs/dev/user_doc/guide/task/flink.json
b/en-us/docs/dev/user_doc/guide/task/flink.json
index 1873203..aa47dc0 100644
--- a/en-us/docs/dev/user_doc/guide/task/flink.json
+++ b/en-us/docs/dev/user_doc/guide/task/flink.json
@@ -1,6 +1,6 @@
{
"filename": "flink.md",
- "__html": "<h1>Flink</h1>\n<h2>Overview</h2>\n<p>Flink task type for
executing Flink programs. For Flink nodes, the worker submits the task by using
the flink command <code>flink run</code>. See <a
href=\"https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/\">flink
cli</a> for more details.</p>\n<h2>Create Task</h2>\n<ul>\n<li>Click Project
Management -> Project Name -> Workflow Definition, and click the
"Create Workflow" button to enter the D [...]
+ "__html": "<h1>Flink</h1>\n<h2>Overview</h2>\n<p>Flink task type for
executing Flink programs. For Flink nodes, the worker submits the task by using
the flink command <code>flink run</code>. See <a
href=\"https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/\">flink
cli</a> for more details.</p>\n<h2>Create Task</h2>\n<ul>\n<li>Click Project
Management -> Project Name -> Workflow Definition, and click the
"Create Workflow" button to enter the D [...]
"link": "/dist/en-us/docs/dev/user_doc/guide/task/flink.html",
"meta": {}
}
\ No newline at end of file
diff --git a/en-us/docs/dev/user_doc/guide/task/map-reduce.html
b/en-us/docs/dev/user_doc/guide/task/map-reduce.html
index 6d90daa..c22d018 100644
--- a/en-us/docs/dev/user_doc/guide/task/map-reduce.html
+++ b/en-us/docs/dev/user_doc/guide/task/map-reduce.html
@@ -36,7 +36,7 @@
<li><strong>Custom parameters</strong>: It is a user-defined parameter that is
part of MapReduce, which will replace the content with ${variable} in the
script.</li>
<li><strong>Predecessor task</strong>: Selecting a predecessor task for the
current task will set the selected predecessor task as upstream of the current
task.</li>
</ul>
-<h3>JAVA /SCALA Program</h3>
+<h3>JAVA/SCALA Program</h3>
<ul>
<li><strong>Program type</strong>: select JAVA/SCALA program.</li>
<li><strong>The class of the main function</strong>: is the full path of the
Main Class, the entry point of the MapReduce program.</li>
@@ -60,13 +60,16 @@
<h2>Task Example</h2>
<h3>Execute the WordCount Program</h3>
<p>This example is a common introductory type of MapReduce application, which
is designed to count the number of identical words in the input text.</p>
+<h4>Configure the MapReduce environment in DolphinScheduler</h4>
+<p>If you are using the MapReduce task type in a production environment, it is
necessary to configure the required environment first. The configuration file
is as follows:
<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>.</p>
+<p><img src="/img/tasks/demo/mr_task01.png" alt="mr_configure"></p>
<h4>Upload the Main Package</h4>
<p>When using the MapReduce task node, you will need to use the Resource
Centre to upload the jar package for the executable. Refer to the <a
href="../resource.md">resource centre</a>.</p>
<p>After configuring the Resource Centre, you can upload the required target
files directly using drag and drop.</p>
-<p><img src="/img/tasks/demo/resource_upload.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>Configure MapReduce Nodes</h4>
<p>Simply configure the required content according to the parameter
descriptions above.</p>
-<p><img src="/img/tasks/demo/mr.png" alt="demo-mr-simple"></p>
+<p><img src="/img/tasks/demo/mr_task02.png" alt="demo-mr-simple"></p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>About us</h3><h4>Do you need feedback? Please
contact us through the following ways.</h4></div><div
class="contact-container"><ul><li><a
href="/en-us/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>Email List</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png [...]
<script
src="//cdn.jsdelivr.net/npm/[email protected]/dist/react-with-addons.min.js"></script>
<script
src="//cdn.jsdelivr.net/npm/[email protected]/dist/react-dom.min.js"></script>
diff --git a/en-us/docs/dev/user_doc/guide/task/map-reduce.json
b/en-us/docs/dev/user_doc/guide/task/map-reduce.json
index 19201ef..6176d28 100644
--- a/en-us/docs/dev/user_doc/guide/task/map-reduce.json
+++ b/en-us/docs/dev/user_doc/guide/task/map-reduce.json
@@ -1,6 +1,6 @@
{
"filename": "map-reduce.md",
- "__html": "<h1>MapReduce</h1>\n<h2>Overview</h2>\n<ul>\n<li>MapReduce(MR)
task type for executing MapReduce programs. For MapReduce nodes, the worker
submits the task by using the Hadoop command <code>hadoop jar</code>. See <a
href=\"https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/CommandsManual.html#jar\">Hadoop
Command Manual</a> for more details.</li>\n</ul>\n<h2>Create
Task</h2>\n<ul>\n<li>Click Project Management-Project Name-Workflow Definition,
and click [...]
+ "__html": "<h1>MapReduce</h1>\n<h2>Overview</h2>\n<ul>\n<li>MapReduce(MR)
task type for executing MapReduce programs. For MapReduce nodes, the worker
submits the task by using the Hadoop command <code>hadoop jar</code>. See <a
href=\"https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/CommandsManual.html#jar\">Hadoop
Command Manual</a> for more details.</li>\n</ul>\n<h2>Create
Task</h2>\n<ul>\n<li>Click Project Management-Project Name-Workflow Definition,
and click [...]
"link": "/dist/en-us/docs/dev/user_doc/guide/task/map-reduce.html",
"meta": {}
}
\ No newline at end of file
diff --git a/en-us/docs/dev/user_doc/guide/task/spark.html
b/en-us/docs/dev/user_doc/guide/task/spark.html
index de21105..6897340 100644
--- a/en-us/docs/dev/user_doc/guide/task/spark.html
+++ b/en-us/docs/dev/user_doc/guide/task/spark.html
@@ -49,13 +49,16 @@
<h2>Task Example</h2>
<h3>Execute the WordCount Program</h3>
<p>This is a common introductory case in the Big Data ecosystem, which often
applied to computational frameworks such as MapReduce, Flink and Spark. The
main purpose is to count the number of identical words in the input text.</p>
+<h4>Configure the Spark environment in DolphinScheduler</h4>
+<p>If you are using the Spark task type in a production environment, it is
necessary to configure the required environment first. The configuration file
is as follows:
<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>.</p>
+<p><img src="/img/tasks/demo/spark_task01.png" alt="spark_configure"></p>
<h4>Upload the Main Package</h4>
<p>When using the Spark task node, you will need to use the Resource Center to
upload the jar package for the executable. Refer to the <a
href="../resource.md">resource center</a>.</p>
<p>After configuring the Resource Center, you can upload the required target
files directly using drag and drop.</p>
-<p><img src="/img/tasks/demo/upload_spark.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>Configure Spark Nodes</h4>
<p>Simply configure the required content according to the parameter
descriptions above.</p>
-<p><img src="/img/tasks/demo/spark_task.png" alt="demo-spark-simple"></p>
+<p><img src="/img/tasks/demo/spark_task02.png" alt="demo-spark-simple"></p>
<h2>Notice</h2>
<p>JAVA and Scala are only used for identification, there is no difference, if
it is Spark developed by Python, there is no class of the main function, the
others are the same.</p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>About us</h3><h4>Do you need feedback? Please
contact us through the following ways.</h4></div><div
class="contact-container"><ul><li><a
href="/en-us/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>Email List</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png [...]
diff --git a/en-us/docs/dev/user_doc/guide/task/spark.json
b/en-us/docs/dev/user_doc/guide/task/spark.json
index 5513deb..a72f43f 100644
--- a/en-us/docs/dev/user_doc/guide/task/spark.json
+++ b/en-us/docs/dev/user_doc/guide/task/spark.json
@@ -1,6 +1,6 @@
{
"filename": "spark.md",
- "__html": "<h1>Spark</h1>\n<h2>Overview</h2>\n<p>Spark task type for
executing Spark programs. For Spark nodes, the worker submits the task by using
the spark command <code>spark submit</code>. See <a
href=\"https://spark.apache.org/docs/3.2.1/submitting-applications.html#launching-applications-with-spark-submit\">spark-submit</a>
for more details.</p>\n<h2>Create Task</h2>\n<ul>\n<li>Click Project
Management -> Project Name -> Workflow Definition, and click the
"Create Work [...]
+ "__html": "<h1>Spark</h1>\n<h2>Overview</h2>\n<p>Spark task type for
executing Spark programs. For Spark nodes, the worker submits the task by using
the spark command <code>spark submit</code>. See <a
href=\"https://spark.apache.org/docs/3.2.1/submitting-applications.html#launching-applications-with-spark-submit\">spark-submit</a>
for more details.</p>\n<h2>Create Task</h2>\n<ul>\n<li>Click Project
Management -> Project Name -> Workflow Definition, and click the
"Create Work [...]
"link": "/dist/en-us/docs/dev/user_doc/guide/task/spark.html",
"meta": {}
}
\ No newline at end of file
diff --git a/img/tasks/demo/flink_task01.png b/img/tasks/demo/flink_task01.png
new file mode 100644
index 0000000..6467070
Binary files /dev/null and b/img/tasks/demo/flink_task01.png differ
diff --git a/img/tasks/demo/flink_task02.png b/img/tasks/demo/flink_task02.png
new file mode 100644
index 0000000..2c352af
Binary files /dev/null and b/img/tasks/demo/flink_task02.png differ
diff --git a/img/tasks/demo/mr_task01.png b/img/tasks/demo/mr_task01.png
new file mode 100644
index 0000000..340e9cd
Binary files /dev/null and b/img/tasks/demo/mr_task01.png differ
diff --git a/img/tasks/demo/mr_task02.png b/img/tasks/demo/mr_task02.png
new file mode 100644
index 0000000..4b6fbf9
Binary files /dev/null and b/img/tasks/demo/mr_task02.png differ
diff --git a/img/tasks/demo/spark_task01.png b/img/tasks/demo/spark_task01.png
new file mode 100644
index 0000000..506b1dc
Binary files /dev/null and b/img/tasks/demo/spark_task01.png differ
diff --git a/img/tasks/demo/spark_task02.png b/img/tasks/demo/spark_task02.png
new file mode 100644
index 0000000..18e0e90
Binary files /dev/null and b/img/tasks/demo/spark_task02.png differ
diff --git a/img/tasks/demo/upload_jar.png b/img/tasks/demo/upload_jar.png
new file mode 100644
index 0000000..a9b71cb
Binary files /dev/null and b/img/tasks/demo/upload_jar.png differ
diff --git a/zh-cn/docs/dev/user_doc/guide/task/flink.html
b/zh-cn/docs/dev/user_doc/guide/task/flink.html
index 1c4802d..3a828ce 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/flink.html
+++ b/zh-cn/docs/dev/user_doc/guide/task/flink.html
@@ -50,13 +50,16 @@
<h2>任务样例</h2>
<h3>执行 WordCount 程序</h3>
<p>本案例为大数据生态中常见的入门案例,常应用于 MapReduce、Flink、Spark
等计算框架。主要为统计输入的文本中,相同的单词的数量有多少。(Flink 的 Releases 附带了此示例作业)</p>
+<h4>在 DolphinScheduler 中配置 flink 环境</h4>
+<p>若生产环境中要是使用到 flink
任务类型,则需要先配置好所需的环境。配置文件如下:<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>。</p>
+<p><img src="/img/tasks/demo/flink_task01.png" alt="flink-configure"></p>
<h4>上传主程序包</h4>
<p>在使用 Flink 任务节点时,需要利用资源中心上传执行程序的 jar 包,可参考<a
href="../resource.md">资源中心</a>。</p>
<p>当配置完成资源中心之后,直接使用拖拽的方式,即可上传所需目标文件。</p>
-<p><img src="/img/tasks/demo/upload_flink.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>配置 Flink 节点</h4>
<p>根据上述参数说明,配置所需的内容即可。</p>
-<p><img src="/img/tasks/demo/flink_task.png" alt="demo-flink-simple"></p>
+<p><img src="/img/tasks/demo/flink_task02.png" alt="demo-flink-simple"></p>
<h2>注意事项:</h2>
<p>Java 和 Scala 只是用来标识,没有区别,如果是 Python 开发的 Flink 则没有主函数的 class,其余的都一样。</p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>联系我们</h3><h4>有问题需要反馈?请通过以下方式联系我们。</h4></div><div
class="contact-container"><ul><li><a
href="/zh-cn/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>邮件列表</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png"/><img class="img-change"
src="/img/twitterblue.png"/><p [...]
diff --git a/zh-cn/docs/dev/user_doc/guide/task/flink.json
b/zh-cn/docs/dev/user_doc/guide/task/flink.json
index 9dff256..c6a44f3 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/flink.json
+++ b/zh-cn/docs/dev/user_doc/guide/task/flink.json
@@ -1,6 +1,6 @@
{
"filename": "flink.md",
- "__html": "<h1>Flink节点</h1>\n<h2>综述</h2>\n<p>Flink 任务类型,用于执行 Flink 程序。对于
Flink 节点,worker 会通过使用 flink 命令 <code>flink run</code> 的方式提交任务。更多详情查看 <a
href=\"https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/\">flink
cli</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>点击项目管理-项目名称-工作流定义,点击“创建工作流”按钮,进入 DAG
编辑页面;</li>\n<li>拖动工具栏的 <img src=\"/img/tasks/icons/flink.png\" width=\"15\"/>
任务节点到画板中。</li>\n</ul>\n<h2>任务参数</h2>\n<ul>\n<li>节点名称:设置任务的名称。一个工作流定义中的节点名称是唯一的。</li>\n<li>运行标志:标
[...]
+ "__html": "<h1>Flink节点</h1>\n<h2>综述</h2>\n<p>Flink 任务类型,用于执行 Flink 程序。对于
Flink 节点,worker 会通过使用 flink 命令 <code>flink run</code> 的方式提交任务。更多详情查看 <a
href=\"https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/\">flink
cli</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>点击项目管理-项目名称-工作流定义,点击“创建工作流”按钮,进入 DAG
编辑页面;</li>\n<li>拖动工具栏的 <img src=\"/img/tasks/icons/flink.png\" width=\"15\"/>
任务节点到画板中。</li>\n</ul>\n<h2>任务参数</h2>\n<ul>\n<li>节点名称:设置任务的名称。一个工作流定义中的节点名称是唯一的。</li>\n<li>运行标志:标
[...]
"link": "/dist/zh-cn/docs/dev/user_doc/guide/task/flink.html",
"meta": {}
}
\ No newline at end of file
diff --git a/zh-cn/docs/dev/user_doc/guide/task/map-reduce.html
b/zh-cn/docs/dev/user_doc/guide/task/map-reduce.html
index 9a85bac..afefb3b 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/map-reduce.html
+++ b/zh-cn/docs/dev/user_doc/guide/task/map-reduce.html
@@ -58,13 +58,16 @@
<h2>任务样例</h2>
<h3>执行 WordCount 程序</h3>
<p>该样例为 MapReduce 应用中常见的入门类型,主要为统计输入的文本中,相同单词的数量有多少。</p>
+<h4>在 DolphinScheduler 中配置 MapReduce 环境</h4>
+<p>若生产环境中要是使用到 MapReduce
任务类型,则需要先配置好所需的环境。配置文件如下:<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>。</p>
+<p><img src="/img/tasks/demo/mr_task01.png" alt="mr_configure"></p>
<h4>上传主程序包</h4>
<p>在使用 MapReduce 任务节点时,需要利用资源中心上传执行程序的 jar 包。可参考<a
href="../resource.md">资源中心</a>。</p>
<p>当配置完成资源中心之后,直接使用拖拽的方式,即可上传所需目标文件。</p>
-<p><img src="/img/tasks/demo/resource_upload.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>配置 MapReduce 节点</h4>
<p>根据上述参数说明,配置所需的内容即可。</p>
-<p><img src="/img/tasks/demo/mr.png" alt="demo-mr-simple"></p>
+<p><img src="/img/tasks/demo/mr_task02.png" alt="demo-mr-simple"></p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>联系我们</h3><h4>有问题需要反馈?请通过以下方式联系我们。</h4></div><div
class="contact-container"><ul><li><a
href="/zh-cn/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>邮件列表</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png"/><img class="img-change"
src="/img/twitterblue.png"/><p [...]
<script
src="//cdn.jsdelivr.net/npm/[email protected]/dist/react-with-addons.min.js"></script>
<script
src="//cdn.jsdelivr.net/npm/[email protected]/dist/react-dom.min.js"></script>
diff --git a/zh-cn/docs/dev/user_doc/guide/task/map-reduce.json
b/zh-cn/docs/dev/user_doc/guide/task/map-reduce.json
index 98739ce..423dbac 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/map-reduce.json
+++ b/zh-cn/docs/dev/user_doc/guide/task/map-reduce.json
@@ -1,6 +1,6 @@
{
"filename": "map-reduce.md",
- "__html": "<h1>MapReduce(MR) 节点</h1>\n<h2>综述</h2>\n<p>MapReduce(MR)
任务类型,用于执行 MapReduce 程序。对于 MapReduce 节点,worker 会通过使用 Hadoop 命令 <code>hadoop
jar</code> 的方式提交任务。更多详情查看 <a
href=\"https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/CommandsManual.html#jar\">Hadoop
Command
Manual</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>点击项目管理-项目名称-工作流定义,点击"创建工作流"按钮,进入
DAG 编辑页面。</li>\n<li>拖动工具栏中的 <img src=\"/img/tasks/icons/mr.png\"
width=\"15\"/> 任务节点到画板中,如下图所示:</li>\n</ul>\n<h2 [...]
+ "__html": "<h1>MapReduce(MR) 节点</h1>\n<h2>综述</h2>\n<p>MapReduce(MR)
任务类型,用于执行 MapReduce 程序。对于 MapReduce 节点,worker 会通过使用 Hadoop 命令 <code>hadoop
jar</code> 的方式提交任务。更多详情查看 <a
href=\"https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/CommandsManual.html#jar\">Hadoop
Command
Manual</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>点击项目管理-项目名称-工作流定义,点击"创建工作流"按钮,进入
DAG 编辑页面。</li>\n<li>拖动工具栏中的 <img src=\"/img/tasks/icons/mr.png\"
width=\"15\"/> 任务节点到画板中,如下图所示:</li>\n</ul>\n<h2 [...]
"link": "/dist/zh-cn/docs/dev/user_doc/guide/task/map-reduce.html",
"meta": {}
}
\ No newline at end of file
diff --git a/zh-cn/docs/dev/user_doc/guide/task/spark.html
b/zh-cn/docs/dev/user_doc/guide/task/spark.html
index f8b8255..9dc1902 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/spark.html
+++ b/zh-cn/docs/dev/user_doc/guide/task/spark.html
@@ -53,13 +53,16 @@
<h2>任务样例</h2>
<h3>执行 WordCount 程序</h3>
<p>本案例为大数据生态中常见的入门案例,常应用于 MapReduce、Flink、Spark
等计算框架。主要为统计输入的文本中,相同的单词的数量有多少。</p>
+<h4>在 DolphinScheduler 中配置 Spark 环境</h4>
+<p>若生产环境中要是使用到 Spark
任务类型,则需要先配置好所需的环境。配置文件如下:<code>/dolphinscheduler/conf/env/dolphinscheduler_env.sh</code>。</p>
+<p><img src="/img/tasks/demo/spark_task01.png" alt="spark_configure"></p>
<h4>上传主程序包</h4>
<p>在使用 Spark 任务节点时,需要利用资源中心上传执行程序的 jar 包,可参考<a
href="../resource.md">资源中心</a>。</p>
<p>当配置完成资源中心之后,直接使用拖拽的方式,即可上传所需目标文件。</p>
-<p><img src="/img/tasks/demo/upload_spark.png" alt="resource_upload"></p>
+<p><img src="/img/tasks/demo/upload_jar.png" alt="resource_upload"></p>
<h4>配置 Spark 节点</h4>
<p>根据上述参数说明,配置所需的内容即可。</p>
-<p><img src="/img/tasks/demo/spark_task.png" alt="demo-spark-simple"></p>
+<p><img src="/img/tasks/demo/spark_task02.png" alt="demo-spark-simple"></p>
<h2>注意事项:</h2>
<p>注意:JAVA 和 Scala 只是用来标识,没有区别,如果是 Python 开发的 Spark 则没有主函数的 class,其他都是一样。</p>
</div></section><footer class="footer-container"><div
class="footer-body"><div><h3>联系我们</h3><h4>有问题需要反馈?请通过以下方式联系我们。</h4></div><div
class="contact-container"><ul><li><a
href="/zh-cn/community/development/subscribe.html"><img class="img-base"
src="/img/emailgray.png"/><img class="img-change"
src="/img/emailblue.png"/><p>邮件列表</p></a></li><li><a
href="https://twitter.com/dolphinschedule"><img class="img-base"
src="/img/twittergray.png"/><img class="img-change"
src="/img/twitterblue.png"/><p [...]
diff --git a/zh-cn/docs/dev/user_doc/guide/task/spark.json
b/zh-cn/docs/dev/user_doc/guide/task/spark.json
index a8552ee..efd3ab2 100644
--- a/zh-cn/docs/dev/user_doc/guide/task/spark.json
+++ b/zh-cn/docs/dev/user_doc/guide/task/spark.json
@@ -1,6 +1,6 @@
{
"filename": "spark.md",
- "__html": "<h1>SPARK节点</h1>\n<h2>综述</h2>\n<p>Spark 任务类型,用于执行 Spark 程序。对于
Spark 节点,worker 会通关使用 spark 命令 <code>spark submit</code> 方式提交任务。更多详情查看 <a
href=\"https://spark.apache.org/docs/3.2.1/submitting-applications.html#launching-applications-with-spark-submit\">spark-submit</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>\n<p>点击项目管理
-> 项目名称 -> 工作流定义,点击”创建工作流”按钮,进入 DAG 编辑页面:</p>\n</li>\n<li>\n<p>拖动工具栏的
<img src=\"/img/tasks/icons/spark.png\" width=\"15\"/>
任务节点到画板中。</p>\n</li>\n</ul>\n<h2>任务参 [...]
+ "__html": "<h1>SPARK节点</h1>\n<h2>综述</h2>\n<p>Spark 任务类型,用于执行 Spark 程序。对于
Spark 节点,worker 会通关使用 spark 命令 <code>spark submit</code> 方式提交任务。更多详情查看 <a
href=\"https://spark.apache.org/docs/3.2.1/submitting-applications.html#launching-applications-with-spark-submit\">spark-submit</a>。</p>\n<h2>创建任务</h2>\n<ul>\n<li>\n<p>点击项目管理
-> 项目名称 -> 工作流定义,点击”创建工作流”按钮,进入 DAG 编辑页面:</p>\n</li>\n<li>\n<p>拖动工具栏的
<img src=\"/img/tasks/icons/spark.png\" width=\"15\"/>
任务节点到画板中。</p>\n</li>\n</ul>\n<h2>任务参 [...]
"link": "/dist/zh-cn/docs/dev/user_doc/guide/task/spark.html",
"meta": {}
}
\ No newline at end of file