Repository: falcon Updated Branches: refs/heads/master 6a5d1f3db -> d08d3bdbe
FALCON-1848 Late rerun has to be a forced reun Had accidentally changed it while fixing FALCON-1835 Author: Pallavi Rao <[email protected]> Reviewers: Sandeep Samudrala <[email protected]> Closes #66 from pallavi-rao/1848 Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/d08d3bdb Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/d08d3bdb Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/d08d3bdb Branch: refs/heads/master Commit: d08d3bdbeddc3634e01dbe10f984b180946ee1e1 Parents: 6a5d1f3 Author: Pallavi Rao <[email protected]> Authored: Mon Mar 14 15:06:22 2016 +0530 Committer: Pallavi Rao <[email protected]> Committed: Mon Mar 14 15:06:22 2016 +0530 ---------------------------------------------------------------------- .../java/org/apache/falcon/rerun/handler/LateRerunConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/d08d3bdb/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java ---------------------------------------------------------------------- diff --git a/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java b/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java index e79f122..f224805 100644 --- a/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java +++ b/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java @@ -84,7 +84,7 @@ public class LateRerunConsumer<T extends LateRerunHandler<DelayedQueue<LaterunEv if (StringUtils.isBlank(id)) { id = message.getWfId(); } - handler.getWfEngine(entityType, entityName).reRun(message.getClusterName(), id, null, false); + handler.getWfEngine(entityType, entityName).reRun(message.getClusterName(), id, null, true); LOG.info("Scheduled late rerun for wf-id: {} on cluster: {}", message.getWfId(), message.getClusterName()); } catch (Exception e) {
