ihadoop commented on issue #3490:
URL:
https://github.com/apache/incubator-streampark/issues/3490#issuecomment-1951334849
> 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);
```
--
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]
