Urmi Mustafi created GOBBLIN-1997:
-------------------------------------
Summary: Avoid deleting flowSpec too early
Key: GOBBLIN-1997
URL: https://issues.apache.org/jira/browse/GOBBLIN-1997
Project: Apache Gobblin
Issue Type: Bug
Components: gobblin-service
Reporter: Urmi Mustafi
Assignee: Abhishek Tiwari
[https://github.com/apache/gobblin/blob/67c610117c2b757bb15714826e0b0edc3e6b26a5/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java#L290]
If a non-active host receives and processes the LAUNCH event before the leader
does, then we encounter a SpecNotFoundException when the leader goes to process
the event and the execution of the LAUNCH will be missed. This PR moves the
deletion to the DagManager and does it only after completing addDag to persist
the event and after checking active status.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
