Return-Path: 
 <dev-return-20178-apmail-falcon-dev-archive=falcon.apache.org@falcon.apache.org>
X-Original-To: apmail-falcon-dev-archive@minotaur.apache.org
Delivered-To: apmail-falcon-dev-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 5DC2418366
	for <apmail-falcon-dev-archive@minotaur.apache.org>;
 Tue,  2 Feb 2016 09:18:41 +0000 (UTC)
Received: (qmail 83404 invoked by uid 500); 2 Feb 2016 09:17:42 -0000
Delivered-To: apmail-falcon-dev-archive@falcon.apache.org
Received: (qmail 83364 invoked by uid 500); 2 Feb 2016 09:17:42 -0000
Mailing-List: contact dev-help@falcon.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@falcon.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@falcon.apache.org>
List-Post: <mailto:dev@falcon.apache.org>
List-Id: <dev.falcon.apache.org>
Reply-To: dev@falcon.apache.org
Delivered-To: mailing list dev@falcon.apache.org
Received: (qmail 83353 invoked by uid 99); 2 Feb 2016 09:17:42 -0000
Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Feb 2016 09:17:42 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org)
 with ESMTP id 4B2F51A0170
	for <dev@falcon.apache.org>; Tue,  2 Feb 2016 09:17:42 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 0.427
X-Spam-Level: 
X-Spam-Status: No, score=0.427 tagged_above=-999 required=6.31
	tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01,
	RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.553] autolearn=disabled
Received: from mx1-us-east.apache.org ([10.40.0.8])
	by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new,
 port 10024)
	with ESMTP id L1qeHWAVY6Rj for <dev@falcon.apache.org>;
	Tue,  2 Feb 2016 09:17:41 +0000 (UTC)
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with
 SMTP id 24A3C42A20
	for <dev@falcon.incubator.apache.org>; Tue,  2 Feb 2016 09:17:41 +0000 (UTC)
Received: (qmail 82856 invoked by uid 99); 2 Feb 2016 09:17:40 -0000
Received: from arcas.apache.org (HELO arcas) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Feb 2016 09:17:40 +0000
Received: from arcas.apache.org (localhost [127.0.0.1])
	by arcas (Postfix) with ESMTP id D9DB22C1F64
	for <dev@falcon.incubator.apache.org>; Tue,  2 Feb 2016 09:17:39 +0000 (UTC)
Date: Tue, 2 Feb 2016 09:17:39 +0000 (UTC)
From: "Pragya Mittal (JIRA)" <jira@apache.org>
To: dev@falcon.incubator.apache.org
Message-ID: <JIRA.12935897.1454403304000.274777.1454404659889@Atlassian.JIRA>
In-Reply-To: <JIRA.12935897.1454403304000@Atlassian.JIRA>
References: <JIRA.12935897.1454403304000@Atlassian.JIRA>
 <JIRA.12935897.1454403304591@arcas>
Subject: [jira] [Commented] (FALCON-1807) Late Rerun is not working in
 distributed mode
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394


    [ https://issues.apache.org/jira/browse/FALCON-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15127945#comment-15127945 ] 

Pragya Mittal commented on FALCON-1807:
---------------------------------------

Process definition :
{noformat}
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<process name="ProcessLateRerunTest-agregator" xmlns="uri:falcon:process:0.1">
    <clusters>
        <cluster name="ProcessLateRerunTest-corp">
            <validity start="2016-02-02T09:13Z" end="2016-02-02T09:43Z"/>
        </cluster>
    </clusters>
    <parallel>2</parallel>
    <order>FIFO</order>
    <frequency>minutes(5)</frequency>
    <timezone>UTC</timezone>
    <inputs>
        <input name="inputData" feed="ProcessLateRerunTest-raaw-logs" start="now(0,-1)" end="now(0,0)"/>
    </inputs>
    <outputs>
        <output name="outputData" feed="ProcessLateRerunTest-agregated" instance="now(0,0)"/>
    </outputs>
    <properties>
        <property name="queueName" value="default"/>
    </properties>
    <workflow path="/tmp/falcon-regression/ProcessLateRerunTest/aggregator"/>
    <retry policy="periodic" delay="minutes(10)" attempts="3"/>
    <late-process policy="periodic" delay="minutes(4)">
        <late-input input="inputData" workflow-path="/tmp/falcon-regression/ProcessLateRerunTest/aggregator"/>
    </late-process>
    <ACL owner="pragya" group="dataqa" permission="*"/>
</process>
{noformat}

> Late Rerun is not working in distributed mode
> ---------------------------------------------
>
>                 Key: FALCON-1807
>                 URL: https://issues.apache.org/jira/browse/FALCON-1807
>             Project: Falcon
>          Issue Type: Bug
>          Components: rerun
>    Affects Versions: 0.9
>            Reporter: Pragya Mittal
>            Assignee: Pallavi Rao
>            Priority: Blocker
>
> Ideally late rerun, runs the instance if and when the data becomes available in the late rerun zone. This is not happening currently.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)