Urmi Mustafi created GOBBLIN-2047:
-------------------------------------
Summary: Gracefully handle existing duplicate dagAction store
entry
Key: GOBBLIN-2047
URL: https://issues.apache.org/jira/browse/GOBBLIN-2047
Project: Apache Gobblin
Issue Type: Improvement
Components: gobblin-service
Reporter: Urmi Mustafi
Assignee: Abhishek Tiwari
If a previous dagAction has not been processed already (in the event of service
downtime for example), then we want to gracefully handle an attempt to re-add
the same action by ignoring the add and completing the MALA lease.
{{java.lang.RuntimeException: java.io.IOException: Failure adding action for
DagAction: DagActionStore.DagAction(flowGroup=FILE_BASED_COPY-mufn,
flowName=mufn-holdem_1792467993, flowExecutionId=1713211305981, jobName=,
dagActionType=LAUNCH) in table dag_action_store}}
{{java.io.IOException: Failure adding action for DagAction:
DagActionStore.DagAction(flowGroup=FILE_BASED_COPY-mufn,
flowName=mufn-holdem_1792467993, flowExecutionId=1713211305981, jobName=,
dagActionType=LAUNCH) in table dag_action_store}}
{{java.sql.SQLIntegrityConstraintViolationException: Duplicate entry
'FILE_BASED_COPY-mufn-mufn-holdem_1792467993-1713211305981-LAUNCH' for key
'dag_action_store.PRIMARY'}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)