dolphinscheduler
dolphinscheduler copied to clipboard
[Feature] Task dispatch failed to increase failure retry
Purpose of the pull request
- After the task dispatch fails, it is put into the failed retry queue.
- Assign the retry interval according to the number of retries.
- The retry interval is implemented by polling the delay queue.
- Update dolphinscheduler_postgresql.sql.
Brief change log
#11463
replace #11464
Verify this pull request
Manually verified the change by testing locally.
Codecov Report
Merging #11640 (8b94c93) into dev (511149f) will increase coverage by
0.01%. The diff coverage is27.69%.
@@ Coverage Diff @@
## dev #11640 +/- ##
============================================
+ Coverage 38.67% 38.68% +0.01%
- Complexity 4049 4065 +16
============================================
Files 999 1002 +3
Lines 36728 36790 +62
Branches 4276 4278 +2
============================================
+ Hits 14204 14232 +28
- Misses 20901 20931 +30
- Partials 1623 1627 +4
| Impacted Files | Coverage Δ | |
|---|---|---|
| ...ster/consumer/TaskDispatchFailedQueueConsumer.java | 0.00% <0.00%> (ø) |
|
| ...ver/master/consumer/TaskPriorityQueueConsumer.java | 7.05% <0.00%> (+7.05%) |
:arrow_up: |
| .../server/master/registry/MasterWaitingStrategy.java | 0.00% <0.00%> (ø) |
|
| ...heduler/service/queue/TaskDispatchFailedQueue.java | 0.00% <0.00%> (ø) |
|
| ...scheduler/service/queue/TaskPriorityQueueImpl.java | 77.77% <0.00%> (-22.23%) |
:arrow_down: |
| ...e/dolphinscheduler/service/queue/TaskPriority.java | 55.00% <60.00%> (+4.33%) |
:arrow_up: |
| ...heduler/service/queue/TaskFailedRetryPriority.java | 93.33% <93.33%> (ø) |
|
| .../org/apache/dolphinscheduler/common/Constants.java | 79.16% <100.00%> (+0.90%) |
:arrow_up: |
| ...erver/master/processor/queue/TaskEventService.java | 75.00% <0.00%> (-5.36%) |
:arrow_down: |
| ... and 2 more |
:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more
:warning: This PR do not change database DDL synchronize.
This pull request has been automatically marked as stale because it has not had recent activity for 120 days. It will be closed in 7 days if no further activity occurs.







