ZihanLi58 commented on pull request #3439: URL: https://github.com/apache/gobblin/pull/3439#issuecomment-985882317
> Can you point me to the code where DagManager checks if the "current attempt number" is less than the "max allowed attempt number" ? Does it fetch the currentAttempt from the job status store? https://github.com/apache/gobblin/blob/master/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java#L741 It fetch job status from state store and only check shouldRetry to determine whether retry is needed. we reset retry to false only in event emitted by gobblin service, but if event in service arrives later than cluster's event, then this will not be updated -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
