@@ -23,6 +23,7 @@ zookeeper.sasl.login-context-name: Client
2323` ` `
2424
2525### 1.3 打包
26+
2627进入项目根目录,使用maven打包:
2728` ` ` shell script
2829mvn clean package -Dmaven.test.skip
@@ -41,12 +42,34 @@ mvn clean package -Dmaven.test.skip
4142| |--- xxxsink
4243| |--- xxxside
4344```
44- ### 1.4 快速启动
45+ ### 1.4 快速启动命令
4546
46- #### 1.4.1 启动命令
47+ #### local模式命令
48+ ``` shell script
49+ sh submit.sh
50+ -mode local
51+ -name local_test
52+ -sql F:\d tstack\s tressTest\f linkStreamSql\s tressTest.sql
53+ -localSqlPluginPath F:\d tstack\p roject\f linkStreamSQL\p lugins
54+ ```
4755
56+ #### standalone模式命令
57+ ``` shell script
58+ sh submit.sh
59+ -mode standalone
60+ -sql F:\d tstack\f linkStreamSql\t iezhu\t wodimjoin.sql
61+ -name wtz_standalone_flinkStreamSql
62+ -localSqlPluginPath F:\d tstack\p roject\f linkStreamSQL\p lugins
63+ -remoteSqlPluginPath /home/admin/dtstack/flinkStreamSQL/plugins
64+ -flinkconf F:\d tstack\f linkStreamSql\l ocalhost\f linkConf
65+ -yarnconf F:\d tstack\f linkStreamSql\l ocalhost\h adoop
66+ -flinkJarPath F:\J ava\f link-1.8.2-bin-scala_2.12\f link-1.8.2\l ib
67+ -pluginLoadMode shipfile
68+ -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
69+ ```
70+
71+ #### yarn模式命令
4872``` shell script
49- # 脚本启动
5073sh submit.sh
5174 -mode yarn
5275 -name flink1.10_yarnSession
@@ -57,20 +80,23 @@ sh submit.sh
5780 -yarnconf F:\d tstack\f linkStreamSql\y arnConf_node1
5881 -flinkJarPath F:\d tstack\f link\f link-1.10.0\l ib
5982 -pluginLoadMode shipfile
60- -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
6183 -yarnSessionConf {\" yid\" :\" application_1586851105774_0014\" }
84+ ```
6285
63- # mode: 任务启动的模式
64- # name: 本次任务名称
65- # sql: 本次任务执行sql脚本
66- # localSqPluginPath: 本地插件包根目录地址
67- # remoteSqlPluginPath: flink执行集群上的插件根目录地址
68- # flinkconf: flink配置文件所在目录(local模式下不需要)
69- # yarnconf: Hadoop配置文件(包括hdfs和yarn)所在目录
70- # flinkJarPath: yarnPer模式提交需要指定本地的flink jar存放路径
71- # pluginLoadMode:yarnPer模式下的插件包加载方式
72- # confProp: 其他额外参数配置
73- # yarnSessionConf: yarnSession模式下指定的运行参数,目前只支持指定yid
86+ #### yarnPer模式命令
87+ ``` shell script
88+ sh submit.sh
89+ -mode yarnPer
90+ -sql /home/wen/Desktop/flink_stream_sql_conf/sql/Test01.sql
91+ -name TestAll
92+ -localSqlPluginPath /home/wen/IdeaProjects/flinkStreamSQL/plugins
93+ -remoteSqlPluginPath /home/wen/IdeaProjects/flinkStreamSQL/plugins
94+ -flinkconf /home/wen/Desktop/flink_stream_sql_conf/flinkConf
95+ -yarnconf /home/wen/Desktop/flink_stream_sql_conf/yarnConf_node1
96+ -flinkJarPath /home/wen/Desktop/dtstack/flink-1.8.1/lib
97+ -pluginLoadMode shipfile
98+ -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
99+ -queue c
74100```
75101参数具体细节请看[ 命令参数说明] ( ./config.md )
76102
0 commit comments