-
Notifications
You must be signed in to change notification settings - Fork 5k
[Fix-17109] Recovered workflow host may incorrect #17112
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Fix-17109] Recovered workflow host may incorrect #17112
Conversation
.../org/apache/dolphinscheduler/api/executor/workflow/StopWorkflowInstanceExecutorDelegate.java
Outdated
Show resolved
Hide resolved
yingh0ng
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
ruanwenjun
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, good catch.
| } catch (ServiceException e) { | ||
| throw e; | ||
| } catch (Exception e) { | ||
| log.error("WorkflowInstance stop failed, workflowInstanceId: {}, workflowInstanceName: {}", workflowInstance.getId(), workflowInstance.getName(), e); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we remove this log? Since the exception stack will be logged by aspect.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the following ServiceException didn't contain the original call stack, it won't print to api log, so i added this.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it's not a good way, i'll remove it first.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok, I got you, since ServiceException are seems as expected exception, although it contains the origin stack, but will not log, so we need to change the aspect code to log the exception stack.
|
Please fix the code style. |
fixed |
SbloodyS
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1
…/api/executor/workflow/StopWorkflowInstanceExecutorDelegate.java Co-authored-by: xiangzihao <[email protected]>
78ff9ac to
7fca832
Compare
|



fix #17109
Brief change log
add
sethostinRecoverFailureTaskCommandHandlerandWorkflowFailoverCommandHandlerVerify this pull request
This pull request is code cleanup without any test coverage.
(or)
This pull request is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows:
(or)
Pull Request Notice
Pull Request Notice
If your pull request contains incompatible change, you should also add it to
docs/docs/en/guide/upgrade/incompatible.md