falcon-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ajay Yadava (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FALCON-1714) EntityNotRegisteredException when process with no input/output feed is scheduled
Date Tue, 05 Jan 2016 10:24:39 GMT

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

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

Committed to 0.9
Commit id: 35cbdd3

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

Mime
View raw message