GH-46: Add support the coordiator job submitted to run in far future
--------------------------------------------------------------------
Key: OOZIE-86
URL: https://issues.apache.org/jira/browse/OOZIE-86
Project: Oozie
Issue Type: Bug
Reporter: Hadoop QA
The following code in PriorityDelayQueue.java class
public int compareTo(Delayed o) {
return (int) (getDelay(TimeUnit.MILLISECONDS) -
o.getDelay(TimeUnit.MILLISECONDS));
}
should be replace by something like this:
public int compareTo(Delayed o) {
long diff = (getDelay(TimeUnit.MILLISECONDS) -
o.getDelay(TimeUnit.MILLISECONDS));
if(diff > 0) {
return 1;
} else if(diff < 0) {
return -1;
} else {
return 0;
}
}
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira