-
Notifications
You must be signed in to change notification settings - Fork 4.7k
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
【Master】【Bug】Fix a bug, When the worker service offline, workerNodeInfo cache in master cannot delete the offline worker #15459
Conversation
...ster/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
Outdated
Show resolved
Hide resolved
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## dev #15459 +/- ##
============================================
+ Coverage 38.02% 38.10% +0.08%
- Complexity 4693 4698 +5
============================================
Files 1304 1304
Lines 44812 44818 +6
Branches 4804 4804
============================================
+ Hits 17040 17079 +39
+ Misses 25921 25885 -36
- Partials 1851 1854 +3 ☔ View full report in Codecov by Sentry. |
Co-authored-by: xiangzihao <zihaoxiang@apache.org>
@SbloodyS Hi,Do you think there are any other problem with this PR |
Could you add some UT for it? @alei1206 |
HI, @alei1206 please Run 'mvn spotless:apply' to fix the code style |
@rickchengx Hi,I have modified the code style using |
.../src/test/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManagerTest.java
Show resolved
Hide resolved
Quality Gate passedThe SonarCloud Quality Gate passed, but some issues were introduced. 2 New issues |
Does anyone see the |
@ruanwenjun Hi, I think, when master refresh worker node, only add new worker server to cache, but not delete the offline worker。 if we not handle the delete event, the offline worker server are always in the cache. Additionally, |
Purpose of the pull request
Fix #15370
When the worker service goes offline, delete the worker information from the
workerNodeInfo
cache in masterBrief change log
Verify 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)
If your pull request contain incompatible change, you should also add it to
docs/docs/en/guide/upgrede/incompatible.md