Venkatesh Seetharam created FALCON-732:
------------------------------------------
Summary: Lineage capture for replicated instance is broken
Key: FALCON-732
URL: https://issues.apache.org/jira/browse/FALCON-732
Project: Falcon
Issue Type: Bug
Affects Versions: 0.6
Reporter: Venkatesh Seetharam
Priority: Blocker
Fix For: 0.6
{code}
2014-09-16 11:47:49,295 INFO - [ActiveMQ Session Task:] ~ Adding replicated
feed instance: 2014-03-18T00:00Z (MetadataMappingService:292)
2014-09-16 11:47:49,296 INFO - [ActiveMQ Session Task:] ~ Computing feed
instance for : name=clicks-feed, path=
hdfs://sandbox.hortonworks.com:8020/falcon/demo/bcp/clicks/2014-03-18-00, in
cluster: bcp-cluster (InstanceRelationshipGraphBuilder:193)
2014-09-16 11:47:49,297 DEBUG - [ActiveMQ Session Task:] ~ Finding vertex for:
name=clicks-feed/2014-03-18T00:00Z, type=FEED_INSTANCE
(RelationshipGraphBuilder:87)
2014-09-16 11:47:49,313 INFO - [ActiveMQ Session Task:] ~ Vertex exists?
name=clicks-feed/2014-03-18T00:00Z, type=FEED_INSTANCE, v=null
(InstanceRelationshipGraphBuilder:200)
2014-09-16 11:47:49,314 ERROR - [ActiveMQ Session Task:] ~ Error in listener
org.apache.falcon.metadata.MetadataMappingService
(WorkflowJobEndNotificationService:104)
java.lang.IllegalStateException: FEED_INSTANCE instance vertex must exist
clicks-feed/2014-03-18T00:00Z
at
org.apache.falcon.metadata.InstanceRelationshipGraphBuilder.addReplicatedInstance(InstanceRelationshipGraphBuilder.java:202)
at
org.apache.falcon.metadata.MetadataMappingService.onFeedInstanceReplicated(MetadataMappingService.java:293)
at
org.apache.falcon.metadata.MetadataMappingService.onSuccess(MetadataMappingService.java:269)
at
org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:101)
at
org.apache.falcon.messaging.JMSMessageConsumer.onSuccess(JMSMessageConsumer.java:131)
at
org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:103)
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:1146)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:679)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
