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)

Reply via email to