代码拉取完成,页面将自动刷新
同步操作将从 朱慧培/flink-streaming-platform-web 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
deploy:
docs:
flink-streaming-common: flink流计算相关公共类
flink-streaming-core: flink流计算核心模块
flink-streaming-valication: sql校验模块
flink-streaming-web: web平台模块 1. 2. 用户管理 3. 日志管理 4. 系统配置等.
flink-streaming-web-alarm: web平台报警接口
flink-streaming-web-common: web平台模块公共类
flink-streaming-web-config: web平台配置类
/**
* Controller 层.
* 加载任务详情
* 加载任务报警配置
* 确定任务运行模式,使用对应的实现类启动任务.接口类:JobServerAO
*/
JobConfigApiController.start(Long id,Long savepointId);
/**
* 任务提交主流程
*/
JobYarnServerAOImpl.start(Long id,Long savepointId,String userName){
//1、检查jobConfigDTO 状态等参数
jobBaseServiceAO.checkStart(jobConfigDTO);
//2、将配置的sql 写入本地文件并且返回运行所需参数
JobRunParamDTO jobRunParamDTO=jobBaseServiceAO.writeSqlToFile(jobConfigDTO);
//3、插一条运行日志数据
Long jobRunLogId=jobBaseServiceAO.insertJobRunLog(jobConfigDTO,userName);
//4、变更任务状态(变更为:启动中) 有乐观锁 防止重复提交
jobConfigService.updateStatusByStart(jobConfigDTO.getId(),userName,jobRunLogId,jobConfigDTO.getVersion());
String savepointPath=savepointBackupService.getSavepointPathById(id,savepointId);
//异步提交任务
jobBaseServiceAO.aSyncExecJob(jobRunParamDTO,jobConfigDTO,jobRunLogId,savepointPath);
}
/**
* 异步提交任务
*/
JobBaseServiceAOImpl.aSyncExecJob(JobRunParamDTO jobRunParamDTO,JobConfigDTO jobConfigDTO,Long jobRunLogId,String savepointPath){
// 以yarn-per-job为例
case YARN_PER:
//1、构建执行命令
command=CommandUtil.buildRunCommandForYarnCluster(jobRunParamDTO,jobConfigDTO,savepointPath);
//2、提交任务
appId=this.submitJobForYarn(command,jobConfigDTO,localLog);
break;
}
//提交完成后更新状态.
this.updateStatusAndLog(jobConfigDTO,jobRunLogId,jobStatus,localLog.toString(),appId);
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。