[KAFKA-7790] Fix Bugs in Trogdor Task Expiration - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

If an Agent process is restarted, it will be re-sent the worker specifications for any tasks that are not DONE. The agent will run these tasks for the original time period. It should be fixed to run them only for the remaining task time. There is also a bug where the coordinator can sometimes re-create a worker even when the task is DONE.