[ 
https://issues.apache.org/jira/browse/FALCON-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Sowmya Ramesh updated FALCON-1420:
----------------------------------
    Description: 
FALCON-1091  changed value of property 
WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName() "NONE" to "IGNORE"  in 
ProcessExecutionCoordinatorBuilder.initializeOutputPaths which has introduced 
the bug. For a process if there are no output feed MetadataMappingService 
should not go ahead to add output feed instance.

Message:
2015-08-28 23:43:48,798 INFO  - [ActiveMQ Session Task:] ~ Adding lineage for 
context 
WorkflowExecutionContext{{brokerImplClass=org.apache.activemq.ActiveMQConnectionFactory,
 operation=GENERATE, contextType=POST_PROCESSING, 
logDir=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00//,
 falconInputFeeds=NONE, cluster=primaryCluster, brokerTTL=4320, 
entityType=PROCESS, 
workflowEngineUrl=http://sandbox.hortonworks.com:11000/oozie/, 
brokerUrl=tcp://sandbox.hortonworks.com:61616, entityName=replication-monthly, 
userBrokerImplClass=org.apache.activemq.ActiveMQConnectionFactory, 
subflowId=0000033-150727232450793-oozie-oozi-W@user-action, 
falconInPaths=IGNORE, userJMSNotificationEnabled=true, 
timeStamp=2015-08-28-23-39, feedInstancePaths=IGNORE, userWorkflowVersion=1.0, 
workflowUser=ambari-qa, workflowId=0000033-150727232450793-oozie-oozi-W, 
userBrokerUrl=tcp://sandbox.hortonworks.com:61616?daemon=true, 
status=SUCCEEDED, 
contextFile=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00/replication-monthly-wf-post-exec-context.json,
 userWorkflowName=hdfs-dr-workflow, nominalTime=2015-08-28-23-00, 
feedNames=IGNORE, runId=0, userWorkflowEngine=oozie}} 
(MetadataMappingService:261)


Exception:
{noformat}
2015-08-28 23:43:49,607 ERROR - [ActiveMQ Session Task:] ~ Error in listener 
org.apache.falcon.metadata.MetadataMappingService 
(WorkflowJobEndNotificationService:104)
org.apache.falcon.FalconException: java.lang.RuntimeException: 
java.lang.NullPointerException
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:274)
        at 
org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:101)
        at 
org.apache.falcon.messaging.JMSMessageConsumer.onSuccess(JMSMessageConsumer.java:138)
        at 
org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:110)
        at 
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1229)
        at 
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134)
        at 
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:205)
        at 
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
        at 
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: java.lang.NullPointerException
        at 
com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:176)
        at 
com.tinkerpop.blueprints.util.TransactionRetryHelper.use(TransactionRetryHelper.java:115)
        at 
com.tinkerpop.blueprints.util.TransactionRetryHelper.exponentialBackoff(TransactionRetryHelper.java:94)
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:263)
        ... 11 more
Caused by: java.lang.NullPointerException
        at org.apache.falcon.entity.FeedHelper.getCluster(FeedHelper.java:80)
        at 
org.apache.falcon.entity.FeedHelper.getStorageType(FeedHelper.java:235)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.getFeedInstanceName(InstanceRelationshipGraphBuilder.java:280)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addFeedInstance(InstanceRelationshipGraphBuilder.java:245)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addOutputFeedInstances(InstanceRelationshipGraphBuilder.java:151)
        at 
org.apache.falcon.metadata.MetadataMappingService.onProcessInstanceExecuted(MetadataMappingService.java:304)
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccessfulExecution(MetadataMappingService.java:282)
        at 
org.apache.falcon.metadata.MetadataMappingService.access$100(MetadataMappingService.java:53)
        at 
org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:267)
        at 
org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:264)
        at 
com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:146)
        ... 14 more
{noformat}

  was:
FALCON-1091  changed value of property 
WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName() "NONE" to "IGNORE"  in 
ProcessExecutionCoordinatorBuilder.initializeOutputPaths which has introduced 
the bug. For a process if there are no output feed MetadataMappingService 
should not go ahead to add output feed instance.

{noformat}
2015-08-28 23:43:48,798 INFO  - [ActiveMQ Session Task:] ~ Adding lineage for 
context 
WorkflowExecutionContext{{brokerImplClass=org.apache.activemq.ActiveMQConnectionFactory,
 operation=GENERATE, contextType=POST_PROCESSING, 
logDir=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00//,
 falconInputFeeds=NONE, cluster=primaryCluster, brokerTTL=4320, 
entityType=PROCESS, 
workflowEngineUrl=http://sandbox.hortonworks.com:11000/oozie/, 
brokerUrl=tcp://sandbox.hortonworks.com:61616, entityName=replication-monthly, 
userBrokerImplClass=org.apache.activemq.ActiveMQConnectionFactory, 
subflowId=0000033-150727232450793-oozie-oozi-W@user-action, 
falconInPaths=IGNORE, userJMSNotificationEnabled=true, 
timeStamp=2015-08-28-23-39, feedInstancePaths=IGNORE, userWorkflowVersion=1.0, 
workflowUser=ambari-qa, workflowId=0000033-150727232450793-oozie-oozi-W, 
userBrokerUrl=tcp://sandbox.hortonworks.com:61616?daemon=true, 
status=SUCCEEDED, 
contextFile=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00/replication-monthly-wf-post-exec-context.json,
 userWorkflowName=hdfs-dr-workflow, nominalTime=2015-08-28-23-00, 
feedNames=IGNORE, runId=0, userWorkflowEngine=oozie}} 
(MetadataMappingService:261)
{noformat}

Exception:
{noformat}
2015-08-28 23:43:49,607 ERROR - [ActiveMQ Session Task:] ~ Error in listener 
org.apache.falcon.metadata.MetadataMappingService 
(WorkflowJobEndNotificationService:104)
org.apache.falcon.FalconException: java.lang.RuntimeException: 
java.lang.NullPointerException
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:274)
        at 
org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:101)
        at 
org.apache.falcon.messaging.JMSMessageConsumer.onSuccess(JMSMessageConsumer.java:138)
        at 
org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:110)
        at 
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1229)
        at 
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134)
        at 
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:205)
        at 
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
        at 
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: java.lang.NullPointerException
        at 
com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:176)
        at 
com.tinkerpop.blueprints.util.TransactionRetryHelper.use(TransactionRetryHelper.java:115)
        at 
com.tinkerpop.blueprints.util.TransactionRetryHelper.exponentialBackoff(TransactionRetryHelper.java:94)
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:263)
        ... 11 more
Caused by: java.lang.NullPointerException
        at org.apache.falcon.entity.FeedHelper.getCluster(FeedHelper.java:80)
        at 
org.apache.falcon.entity.FeedHelper.getStorageType(FeedHelper.java:235)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.getFeedInstanceName(InstanceRelationshipGraphBuilder.java:280)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addFeedInstance(InstanceRelationshipGraphBuilder.java:245)
        at 
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addOutputFeedInstances(InstanceRelationshipGraphBuilder.java:151)
        at 
org.apache.falcon.metadata.MetadataMappingService.onProcessInstanceExecuted(MetadataMappingService.java:304)
        at 
org.apache.falcon.metadata.MetadataMappingService.onSuccessfulExecution(MetadataMappingService.java:282)
        at 
org.apache.falcon.metadata.MetadataMappingService.access$100(MetadataMappingService.java:53)
        at 
org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:267)
        at 
org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:264)
        at 
com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:146)
        ... 14 more
{noformat}


> NPE in MetadataMappingService when adding process instance executed
> -------------------------------------------------------------------
>
>                 Key: FALCON-1420
>                 URL: https://issues.apache.org/jira/browse/FALCON-1420
>             Project: Falcon
>          Issue Type: Bug
>    Affects Versions: 0.7
>            Reporter: Sowmya Ramesh
>
> FALCON-1091  changed value of property 
> WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName() "NONE" to "IGNORE"  in 
> ProcessExecutionCoordinatorBuilder.initializeOutputPaths which has introduced 
> the bug. For a process if there are no output feed MetadataMappingService 
> should not go ahead to add output feed instance.
> Message:
> 2015-08-28 23:43:48,798 INFO  - [ActiveMQ Session Task:] ~ Adding lineage for 
> context 
> WorkflowExecutionContext{{brokerImplClass=org.apache.activemq.ActiveMQConnectionFactory,
>  operation=GENERATE, contextType=POST_PROCESSING, 
> logDir=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00//,
>  falconInputFeeds=NONE, cluster=primaryCluster, brokerTTL=4320, 
> entityType=PROCESS, 
> workflowEngineUrl=http://sandbox.hortonworks.com:11000/oozie/, 
> brokerUrl=tcp://sandbox.hortonworks.com:61616, 
> entityName=replication-monthly, 
> userBrokerImplClass=org.apache.activemq.ActiveMQConnectionFactory, 
> subflowId=0000033-150727232450793-oozie-oozi-W@user-action, 
> falconInPaths=IGNORE, userJMSNotificationEnabled=true, 
> timeStamp=2015-08-28-23-39, feedInstancePaths=IGNORE, 
> userWorkflowVersion=1.0, workflowUser=ambari-qa, 
> workflowId=0000033-150727232450793-oozie-oozi-W, 
> userBrokerUrl=tcp://sandbox.hortonworks.com:61616?daemon=true, 
> status=SUCCEEDED, 
> contextFile=hdfs://sandbox.hortonworks.com:8020/apps/falcon/primaryCluster/staging/falcon/workflows/process/replication-monthly/logs/job-2015-08-28-23-00/replication-monthly-wf-post-exec-context.json,
>  userWorkflowName=hdfs-dr-workflow, nominalTime=2015-08-28-23-00, 
> feedNames=IGNORE, runId=0, userWorkflowEngine=oozie}} 
> (MetadataMappingService:261)
> Exception:
> {noformat}
> 2015-08-28 23:43:49,607 ERROR - [ActiveMQ Session Task:] ~ Error in listener 
> org.apache.falcon.metadata.MetadataMappingService 
> (WorkflowJobEndNotificationService:104)
> org.apache.falcon.FalconException: java.lang.RuntimeException: 
> java.lang.NullPointerException
>       at 
> org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:274)
>       at 
> org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:101)
>       at 
> org.apache.falcon.messaging.JMSMessageConsumer.onSuccess(JMSMessageConsumer.java:138)
>       at 
> org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:110)
>       at 
> org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1229)
>       at 
> org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134)
>       at 
> org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:205)
>       at 
> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
>       at 
> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
>       at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>       at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>       at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.RuntimeException: java.lang.NullPointerException
>       at 
> com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:176)
>       at 
> com.tinkerpop.blueprints.util.TransactionRetryHelper.use(TransactionRetryHelper.java:115)
>       at 
> com.tinkerpop.blueprints.util.TransactionRetryHelper.exponentialBackoff(TransactionRetryHelper.java:94)
>       at 
> org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:263)
>       ... 11 more
> Caused by: java.lang.NullPointerException
>       at org.apache.falcon.entity.FeedHelper.getCluster(FeedHelper.java:80)
>       at 
> org.apache.falcon.entity.FeedHelper.getStorageType(FeedHelper.java:235)
>       at 
> org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.getFeedInstanceName(InstanceRelationshipGraphBuilder.java:280)
>       at 
> org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addFeedInstance(InstanceRelationshipGraphBuilder.java:245)
>       at 
> org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addOutputFeedInstances(InstanceRelationshipGraphBuilder.java:151)
>       at 
> org.apache.falcon.metadata.MetadataMappingService.onProcessInstanceExecuted(MetadataMappingService.java:304)
>       at 
> org.apache.falcon.metadata.MetadataMappingService.onSuccessfulExecution(MetadataMappingService.java:282)
>       at 
> org.apache.falcon.metadata.MetadataMappingService.access$100(MetadataMappingService.java:53)
>       at 
> org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:267)
>       at 
> org.apache.falcon.metadata.MetadataMappingService$3.execute(MetadataMappingService.java:264)
>       at 
> com.tinkerpop.blueprints.util.TransactionRetryStrategy$AbstractRetryStrategy.execute(TransactionRetryStrategy.java:146)
>       ... 14 more
> {noformat}



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

Reply via email to