You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by le...@apache.org on 2022/09/20 01:11:58 UTC
[incubator-linkis] branch dev-1.3.0 updated: [Feature] Add sample to start a flink job on per-job cluster mode in LDH (#3471)
This is an automated email from the ASF dual-hosted git repository.
legendtkl pushed a commit to branch dev-1.3.0
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.3.0 by this push:
new 2000027b9 [Feature] Add sample to start a flink job on per-job cluster mode in LDH (#3471)
2000027b9 is described below
commit 2000027b9e5ffa8a0172ad4b15dee0b582f801da
Author: Aaron Lin <51...@users.noreply.github.com>
AuthorDate: Tue Sep 20 09:11:50 2022 +0800
[Feature] Add sample to start a flink job on per-job cluster mode in LDH (#3471)
---
linkis-dist/helm/README.md | 4 ++++
linkis-dist/helm/README_CN.md | 4 ++++
2 files changed, 8 insertions(+)
diff --git a/linkis-dist/helm/README.md b/linkis-dist/helm/README.md
index efd38294f..b27d5a371 100644
--- a/linkis-dist/helm/README.md
+++ b/linkis-dist/helm/README.md
@@ -308,6 +308,10 @@ dataLength = 0
numChildren = 0
[zk: localhost:2181(CONNECTED) 1] quit
+# Run flink job on per-job cluster mode
+[root@ldh-96bdc757c-dnkbs /]# HADOOP_CLASSPATH=`hadoop classpath` flink run -t yarn-per-job /opt/ldh/current/flink/examples/streaming/TopSpeedWindowing.jar
+# Run flink job on session cluster mode,
+# A Flink session on YARN has been started when the LDH Pod starts
[root@ldh-96bdc757c-dnkbs /]# flink run /opt/ldh/current/flink/examples/streaming/TopSpeedWindowing.jar
Executing TopSpeedWindowing example with default input data set.
Use --input to specify file input.
diff --git a/linkis-dist/helm/README_CN.md b/linkis-dist/helm/README_CN.md
index 3ac88500a..06b3e08e9 100644
--- a/linkis-dist/helm/README_CN.md
+++ b/linkis-dist/helm/README_CN.md
@@ -307,6 +307,10 @@ dataLength = 0
numChildren = 0
[zk: localhost:2181(CONNECTED) 1] quit
+# 以 per-job cluster 模式启动 Flink 作业
+[root@ldh-96bdc757c-dnkbs /]# HADOOP_CLASSPATH=`hadoop classpath` flink run -t yarn-per-job /opt/ldh/current/flink/examples/streaming/TopSpeedWindowing.jar
+# 以 session 模式启动 Flink 作业,
+# Flink session 在 LDH Pod 启动时会被启动了一个.
[root@ldh-96bdc757c-dnkbs /]# flink run /opt/ldh/current/flink/examples/streaming/TopSpeedWindowing.jar
Executing TopSpeedWindowing example with default input data set.
Use --input to specify file input.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org