@@ -46,7 +46,27 @@ mvn clean package -Dmaven.test.skip
4646#### 1.4.1 启动命令
4747
4848``` shell script
49- # 脚本启动
49+ # local模式命令
50+ sh submit.sh
51+ -mode local
52+ -name local_test
53+ -sql F:\d tstack\s tressTest\f linkStreamSql\s tressTest.sql
54+ -localSqlPluginPath F:\d tstack\p roject\f linkStreamSQL\p lugins
55+
56+ # standalone模式命令
57+ sh submit.sh
58+ -mode standalone
59+ -sql F:\d tstack\f linkStreamSql\t iezhu\t wodimjoin.sql
60+ -name wtz_standalone_flinkStreamSql
61+ -localSqlPluginPath F:\d tstack\p roject\f linkStreamSQL\p lugins
62+ -remoteSqlPluginPath /home/admin/dtstack/flinkStreamSQL/plugins
63+ -flinkconf F:\d tstack\f linkStreamSql\l ocalhost\f linkConf
64+ -yarnconf F:\d tstack\f linkStreamSql\l ocalhost\h adoop
65+ -flinkJarPath F:\J ava\f link-1.8.2-bin-scala_2.12\f link-1.8.2\l ib
66+ -pluginLoadMode shipfile
67+ -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
68+
69+ # yarn模式命令
5070sh submit.sh
5171 -mode yarn
5272 -name flink1.10_yarnSession
@@ -57,20 +77,22 @@ sh submit.sh
5777 -yarnconf F:\d tstack\f linkStreamSql\y arnConf_node1
5878 -flinkJarPath F:\d tstack\f link\f link-1.10.0\l ib
5979 -pluginLoadMode shipfile
60- -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
6180 -yarnSessionConf {\" yid\" :\" application_1586851105774_0014\" }
6281
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
82+ # yarnPer模式命令
83+ sh submit.sh
84+ -mode yarnPer
85+ -sql /home/wen/Desktop/flink_stream_sql_conf/sql/Test01.sql
86+ -name TestAll
87+ -localSqlPluginPath /home/wen/IdeaProjects/flinkStreamSQL/plugins
88+ -remoteSqlPluginPath /home/wen/IdeaProjects/flinkStreamSQL/plugins
89+ -flinkconf /home/wen/Desktop/flink_stream_sql_conf/flinkConf
90+ -yarnconf /home/wen/Desktop/flink_stream_sql_conf/yarnConf_node1
91+ -flinkJarPath /home/wen/Desktop/dtstack/flink-1.8.1/lib
92+ -pluginLoadMode shipfile
93+ -confProp {\" time.characteristic\" :\" eventTime\" ,\" logLevel\" :\" info\" }
94+ -queue c
95+
7496```
7597参数具体细节请看[ 命令参数说明] ( ./config.md )
7698
0 commit comments