You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@falcon.apache.org by sandeep samudrala <sa...@gmail.com> on 2015/09/03 09:13:13 UTC

Review Request 38090: Feed update with replication delay

-----------------------------------------------------------
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