@@ -9,8 +9,8 @@ sh submit.sh -key1 val1 -key2 val2
99 * 描述:执行模式,也就是flink集群的工作模式
1010 * local: 本地模式
1111 * standalone: 提交到独立部署模式的flink集群
12- * yarn: 提交到yarn模式的flink集群(即提交到已有flink集群)
13- * yarnPer: yarn per_job模式提交(即创建新flink application)
12+ * yarn: 提交到yarn模式的flink集群,该模式下需要提前启动一个yarn-session,使用默认名"Flink session cluster"
13+ * yarnPer: yarn per_job模式提交(即创建新flink application),默认名为flink任务名称
1414 * 必选:否
1515 * 默认值:local
1616
@@ -28,7 +28,7 @@ sh submit.sh -key1 val1 -key2 val2
2828 * 默认值:无
2929
3030* ** sql**
31- * 描述:执行flink sql 的主体语句 。
31+ * 描述:待执行的flink sql所在路径 。
3232 * 必选:是
3333 * 默认值:无
3434
@@ -44,15 +44,13 @@ sh submit.sh -key1 val1 -key2 val2
4444
4545* ** addjar**
4646 * 描述:扩展jar路径,当前主要是UDF定义的jar;
47- * 格式:json
4847 * 必选:否
4948 * 默认值:无
5049
5150* ** confProp**
5251 * 描述:一些参数设置
53- * 格式: json
54- * 必选:是 (如无参数填写空json即可)
55- * 默认值:无
52+ * 必选:否
53+ * 默认值:{}
5654 * 可选参数:
5755 * sql.ttl.min: 最小过期时间,大于0的整数,如1d、1h(d\D:天,h\H:小时,m\M:分钟,s\s:秒)
5856 * sql.ttl.max: 最大过期时间,大于0的整数,如2d、2h(d\D:天,h\H:小时,m\M:分钟,s\s:秒),需同时设置最小时间,且比最小时间大5分钟
@@ -79,7 +77,7 @@ sh submit.sh -key1 val1 -key2 val2
7977
8078
8179* ** flinkconf**
82- * 描述:flink配置文件所在的目录(单机模式下不需要),如/hadoop/flink-1.4 .0/conf
80+ * 描述:flink配置文件所在的目录(单机模式下不需要),如/hadoop/flink-1.10 .0/conf
8381 * 必选:否
8482 * 默认值:无
8583
@@ -91,15 +89,15 @@ sh submit.sh -key1 val1 -key2 val2
9189* ** flinkJarPath**
9290 * 描述:yarnPer 模式提交需要指定本地的flink jar存放路径
9391 * 必选:否
94- * 默认值:false
92+ * 默认值:无
9593
9694* ** queue**
9795 * 描述:yarnPer 模式下指定的yarn queue
9896 * 必选:否
99- * 默认值:false
97+ * 默认值:default
10098
10199* ** yarnSessionConf**
102100 * 描述:yarn session 模式下指定的运行的一些参数,[可参考](https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/cli.html),目前只支持指定yid
103101 * 必选:否
104- * 默认值:false
102+ * 默认值:{}
105103
0 commit comments