Urmi Mustafi created GOBBLIN-2019:
-------------------------------------
Summary: Remove Circular Dependency & Initialize multi-active
execution classes
Key: GOBBLIN-2019
URL: https://issues.apache.org/jira/browse/GOBBLIN-2019
Project: Apache Gobblin
Issue Type: Improvement
Components: gobblin-service
Reporter: Urmi Mustafi
Assignee: Abhishek Tiwari
The following PR removes a circular dependency between
{{dagManagementTaskStream & }}{{{}ReminderSettingDagProcLeaseArbiter{}}}{{{}.
{}}}
describing the circular dependency: {{dagManagementTaskStream}} uses
{{ReminderSettingDagProcLeaseArbiter}} to obtain lease, if it fails to obtain
lease then the {{ReminderSettingDagProcLeaseArbiter}} was setting reminder on
{{DagActionReminderScheduler}} and when reminder fires add the action back to
{{{}dagManagementTaskStream{}}}. To remove circular dependency, I remove the
{{ReminderSettingDagProcLeaseArbiter}} and use the more generic
{{InstrumentedLeaseArbiter}} that will only provide the status. Instead,
{{dagManagementTaskStream}} will call {{DagActionReminderScheduler}} to set
reminders and re-add to task stream
other changes
* refactor {{MySqlMultiActiveLeaseArbiter}} and it's initialization to specify
table names through a prefix to differentiate btwn multiple instances
* adds {{jobName}} to {{dagActionChangeEvent}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)