xiaohui2009 opened a new issue, #15089:
URL: https://github.com/apache/dolphinscheduler/issues/15089

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and 
found no similar issues.
   
   
   ### What happened
   
   flink stream任务执行完成后无法停止和savepoint
   
   ### What you expected to happen
   
   flink stream任务执行完成可以停止和savepoint
   
   ### How to reproduce
   
   新建flink stream 任务启动,然后执行停止操作
   
   
主要原因是WorkerTaskExecuteRunnable执行任务后,从TaskExecutionContextCacheManager清理了taskInstanceId,导致停止任务执行时无法从TaskExecutionContextCacheManager通过taskInstanceId获取任务信息
   
   ### Anything else
   
   _No response_
   
   ### Version
   
   dev
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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]

Reply via email to