[ https://issues.apache.org/jira/browse/OOZIE-3031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197756#comment-16197756 ]
Satish Subhashrao Saley commented on OOZIE-3031: ------------------------------------------------ +1 > Coord job with only unresolved dependencies doesn't timeout > ----------------------------------------------------------- > > Key: OOZIE-3031 > URL: https://issues.apache.org/jira/browse/OOZIE-3031 > Project: Oozie > Issue Type: Bug > Reporter: Purshotam Shah > Assignee: Purshotam Shah > Priority: Critical > Attachments: OOZIE-3031-V1.patch, OOZIE-3031-V2.patch > > > {code:title=CoordActionInputCheckXCommand.java} > else if (!isTimeout(currentTime)) { > if (!status) { > long addtionalDelay = isChangeInDependency ? 0 > : > ConfigurationService.getInt(CONF_COORD_INPUT_CHECK_REQUEUE_INTERVAL_ADDITIONAL_DELAY) > * 1000L; > queue(new > CoordActionInputCheckXCommand(coordAction.getId(), coordAction.getJobId()), > addtionalDelay + > getCoordInputCheckRequeueInterval()); > } > updateCoordAction(coordAction, isChangeInDependency); > } > else { > if (!nonExistListStr.isEmpty() && isPushDependenciesMet) { > queue(new CoordActionTimeOutXCommand(coordAction, > coordJob.getUser(), coordJob.getAppName())); > } > else { > // Let CoordPushDependencyCheckXCommand queue the timeout > queue(new > CoordPushDependencyCheckXCommand(coordAction.getId())); > } > updateCoordAction(coordAction, isChangeInDependency); > } > } > {code} > {{!nonExistList Str.isEmpty()}} check is unnecessary, once the action has > passed the timeout, it should be marked as timedout. -- This message was sent by Atlassian JIRA (v6.4.14#64029)