Mailing-List: contact dev-help@falcon.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@falcon.apache.org
Date: Tue, 5 Jan 2016 03:56:39 +0000 (UTC)
From: "Ajay Yadava (JIRA)" <jira@apache.org>
To: dev@falcon.incubator.apache.org
Message-ID: <JIRA.12925012.1451553063000.17156.1451966199822@Atlassian.JIRA>
In-Reply-To: <JIRA.12925012.1451553063000@Atlassian.JIRA>
References: <JIRA.12925012.1451553063000@Atlassian.JIRA>
 <JIRA.12925012.1451553063900@arcas>
Subject: [jira] [Commented] (FALCON-1714) EntityNotRegisteredException when
 process with no input/output feed is scheduled
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


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

Ajay Yadava commented on FALCON-1714:
-------------------------------------

Thanks [~peeyushb], [~sowmyaramesh] & [~bvellanki] for reviewing. Will commit today if there are no other review comments.

> EntityNotRegisteredException when process with no input/output feed is scheduled
> --------------------------------------------------------------------------------
>
>                 Key: FALCON-1714
>                 URL: https://issues.apache.org/jira/browse/FALCON-1714
>             Project: Falcon
>          Issue Type: Bug
>    Affects Versions: trunk
>            Reporter: Pragya Mittal
>            Assignee: Ajay Yadava
>             Fix For: 0.9
>
>         Attachments: FALCON-1714.patch
>
>
> When a process with no input and output feed is scheduled , the server logs show the following error :
> {noformat}
> 2015-12-31 09:02:34,804 ERROR - [ActiveMQ Session Task-124:] ~ Error in listener org.apache.falcon.handler.SLAMonitoringHandler (WorkflowJobEndNotificationService:245)
> org.apache.falcon.entity.EntityNotRegisteredException: NONE (FEED) not found
> 	at org.apache.falcon.entity.EntityUtil.getEntity(EntityUtil.java:121)
> 	at org.apache.falcon.handler.SLAMonitoringHandler.updateSLAMonitoring(SLAMonitoringHandler.java:56)
> 	at org.apache.falcon.handler.SLAMonitoringHandler.onSuccess(SLAMonitoringHandler.java:47)
> 	at org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifyWorkflowEnd(WorkflowJobEndNotificationService.java:235)
> 	at org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:105)
> 	at org.apache.falcon.messaging.JMSMessageConsumer.invokeListener(JMSMessageConsumer.java:218)
> 	at org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:121)
> 	at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1393)
> 	at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:131)
> 	at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:202)
> 	at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
> 	at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> 	at java.lang.Thread.run(Thread.java:745)
> 2015-12-31 09:02:34,804 INFO  - [ActiveMQ Session Task-124:] ~ {Action:wf-instance-succeeded, Dimensions:{entity-type=PROCESS, nominal-time=2015-12-31T09:02Z, cluster=ProcessWfTest-corp-8be6d87c, start-time=2015-12-31T09:02Z, entity-name=ProcessWfTest-agregator-coord16-0caad7d5, wf-id=0000708-151230090106575-oozie-oozi-W, run-id=0, wf-user=dataqa, operation=GENERATE}, Status: SUCCEEDED, Time-taken:26744000000 ns} (METRIC:38)
> {noformat}
> The process definition is :
> {noformat}
> dataqa@lda01:~$ fep -definition -name ProcessWfTest-agregator-coord16-0caad7d5
> <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
> <process name="ProcessWfTest-agregator-coord16-0caad7d5" xmlns="uri:falcon:process:0.1">
>     <clusters>
>         <cluster name="ProcessWfTest-corp-8be6d87c">
>             <validity start="2015-12-31T05:47Z" end="2015-12-31T10:47Z"/>
>         </cluster>
>     </clusters>
>     <parallel>4</parallel>
>     <order>FIFO</order>
>     <frequency>minutes(1)</frequency>
>     <timezone>UTC</timezone>
>     <properties>
>         <property name="queueName" value="default"/>
>         <property name="fileTime" value="${formatTime(dateOffset(instanceTime(), 1, 'DAY'), 'yyyy-MMM-dd')}"/>
>         <property name="user" value="${user()}"/>
>     </properties>
>     <workflow path="/tmp/falcon-regression/ProcessWfTest/aggregator"/>
>     <retry policy="periodic" delay="minutes(3)" attempts="3"/>
>     <ACL owner="pragya" group="dataqa" permission="*"/>
> </process>
> {noformat}


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