falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pall...@apache.org
Subject falcon git commit: FALCON-1848 Late rerun has to be a forced reun
Date Mon, 14 Mar 2016 09:36:34 GMT
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 <pallavi.rao@inmobi.com>

Reviewers: Sandeep Samudrala <sandeep.samudrala@inmobi.com>

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 <pallavi.rao@inmobi.com>
Authored: Mon Mar 14 15:06:22 2016 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
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) {


Mime
View raw message