我在同一个Flink项目中有多个作业。我想知道,当我向Flink集群提交作业时,我不知道这个提交的jar正在运行whic作业。例如
我在同一个flink项目中有两个作业,创建jar,然后将其部署到集群中。然后我用同一个罐子提交两个作业。
然后我更改job2,并创建新的jar文件。然后用新上传的jar提交job2。
在这种情况下,当我查看提交UI时,我真的不知道哪个作业是从这个jar提交的。
为了防止这种情况,我可以创建多个具有不同jar名称的flink项目。
注意:我使用的是CI/CD管道,如果我在同一个项目中有多个作业,我就不能动态创建jar名称。
这方面的最佳实践是什么?
您可以在执行flink run命令时指定作业名称,方法是将参数传递到主类,然后在env.execute(params.get('your-job-name'((中使用该值。这样,您就可以使用同一个jar并传递不同的作业名称,以便在部署后在flink dashboard中区分它。