chunjun
chunjun copied to clipboard
自定义flink jobId
为了防止重复提交作业,如果提交任务传如果提入了jobId并且长度为32位那么就使用该jobId作为flink任务运行的jobId。 如果没传入jobId,那么就使用flink自己生成的jobId
关联的issue是 758
感谢提交的pr,有几点需要调整下:
- 代码格式化了嘛?纯钧使用的是spotless 插件对代码格式化,如果不符合格式要求,项目则无法编译成功,所以在提交之前,需要执行下spotless:apply命令;
- pr commit message 不合纯钧规范,我们对pr的规范(规范在文档里有说明)是:
- 在pr里备注修复的issue;
- pr commit 模版[hotfix-#issueID][#fix-module] #fix-commit.
- 修改内容尽量保持与issue内容一致,如果出现无关修改,在pr中备注出来; 可以观察下git log 里其他同学是如果提交commit 信息的。
另外,pr message及代码注释采用英文。