chunjun icon indicating copy to clipboard operation
chunjun copied to clipboard

自定义flink jobId

Open shaolei7788 opened this issue 3 years ago • 2 comments

为了防止重复提交作业,如果提交任务传如果提入了jobId并且长度为32位那么就使用该jobId作为flink任务运行的jobId。 如果没传入jobId,那么就使用flink自己生成的jobId

关联的issue是 758

shaolei7788 avatar May 20 '22 03:05 shaolei7788

感谢提交的pr,有几点需要调整下:

  1. 代码格式化了嘛?纯钧使用的是spotless 插件对代码格式化,如果不符合格式要求,项目则无法编译成功,所以在提交之前,需要执行下spotless:apply命令;
  2. pr commit message 不合纯钧规范,我们对pr的规范(规范在文档里有说明)是:
  • 在pr里备注修复的issue;
  • pr commit 模版[hotfix-#issueID][#fix-module] #fix-commit.
  • 修改内容尽量保持与issue内容一致,如果出现无关修改,在pr中备注出来; 可以观察下git log 里其他同学是如果提交commit 信息的。

FlechazoW avatar May 20 '22 03:05 FlechazoW

另外,pr message及代码注释采用英文。

FlechazoW avatar May 20 '22 03:05 FlechazoW