ihadoop commented on issue #3490: URL: https://github.com/apache/incubator-streampark/issues/3490#issuecomment-1960828832
> > > I didn't modify the cluster_id, I just copied a task and filled in the app_name I needed. 在 2024-02-18 14:41:37，"sunshine" _**@**_._**> 写道： hi，i want to fix this bug。 Looking forward to your PR to fix this bug! ️ hi，i viewed the code and found that when job is not session model, original job name will be set as cluster_id. i want to know when is not session model ,this value can be set as null Seems to be coming from the front end, maybe you need to debug to make sure it’s not from front end，i means why set jobname as cluster_id if is not session model — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: _**@**_.**_> > > > > > > but if old is session mode，it will set new job name as cluster_id,i want to know why ? > > ``` > > newApp.setClusterId( > > FlinkExecutionMode.isSessionMode(oldApp.getFlinkExecutionMode()) > > ? oldApp.getClusterId() > > : jobName); > > ``` > > ？I'll take a look at it later ???? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
