|
@@ -141,7 +141,11 @@ public class Main {
|
|
|
} else {
|
|
|
String odpsCmdPath = commandLine.getOptionValue("odps");
|
|
|
dd.send(msg);
|
|
|
- bean.start(bizDate, jobs, odpsCmdPath);
|
|
|
+ Long time = 90l;
|
|
|
+ if (fileName.endsWith("step06.yaml")) {
|
|
|
+ time = 60 * 6l;
|
|
|
+ }
|
|
|
+ bean.start(bizDate, jobs, odpsCmdPath, time);
|
|
|
// 指定job结束后发送通知
|
|
|
if (fileName.endsWith("step03.yaml")) {
|
|
|
SendJobStatus sendJobStatus = context.getBean(SendJobStatus.class);
|
|
@@ -165,13 +169,13 @@ public class Main {
|
|
|
}
|
|
|
|
|
|
@SneakyThrows
|
|
|
- private void start(String bizDate, List<DataWorksFlowJob> jobs, String odpsCmdHome) {
|
|
|
+ private void start(String bizDate, List<DataWorksFlowJob> jobs, String odpsCmdHome, Long time) {
|
|
|
//为所有项目空间启动守护线程
|
|
|
String accessKeyId = dataWorksAccessProperties.getAccessKeyId();
|
|
|
String accessKeySecret = dataWorksAccessProperties.getAccessKeySecret();
|
|
|
Set<String> ps = jobs.stream().map(DataWorksFlowJob::getProject).collect(Collectors.toSet());
|
|
|
for (String p : ps) {
|
|
|
- new SparkDaemonThread(p, accessKeyId, accessKeySecret, odpsCmdHome, 90L).start();
|
|
|
+ new SparkDaemonThread(p, accessKeyId, accessKeySecret, odpsCmdHome, time).start();
|
|
|
}
|
|
|
|
|
|
//运行job,并接收失败参数,最大重试三次
|