-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/38090/
-----------------------------------------------------------

Review request for Falcon.


Bugs: FALCON-298
    https://issues.apache.org/jira/browse/FALCON-298


Repository: falcon-git


Description
-------

The delays can be different for each source cluster and there by figure out the 
source cluster, which the current coordinator belongs to and then get the delay 
and then add it to the end time of the current old coordinator in the target.


Diffs
-----

  
oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java 
7e6cd6c 

Diff: https://reviews.apache.org/r/38090/diff/


Testing
-------

I have tested with a feed submitted with different sources having different 
delays. I submitted and scheduled a feed with a frequency of 10 minutes and 
delay in one of the source as 1 hour and delay in another source with 2 hours. 
Update of the above feed accordinly updates the coordinators with the 
respective end times in accordance with their source delays. There are no holes 
created after this patch fix.


Thanks,

sandeep samudrala

Reply via email to