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