[
https://issues.apache.org/jira/browse/FALCON-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ajay Yadava updated FALCON-1714:
--------------------------------
Attachment: FALCON-1714.patch
> 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
> 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)
