You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@falcon.apache.org by "Pragya Mittal (JIRA)" <ji...@apache.org> on 2015/12/31 10:13:49 UTC
[jira] [Updated] (FALCON-1714) EntityNotRegisteredException when
process with no input/output feed is scheduled
[ https://issues.apache.org/jira/browse/FALCON-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pragya Mittal updated FALCON-1714:
----------------------------------
Description:
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}
> 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
>
> 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)