Uploaded image for project: 'Falcon'
  1. Falcon
  2. FALCON-732

Lineage capture fails for an instance thats not generated by falcon

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 0.6
    • 0.6
    • None
    • None

    Description

      This is broken for both replication and eviction.

      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)
      

      Attachments

        1. FALCON-732.patch
          16 kB
          Sowmya Ramesh

        Issue Links

          Activity

            People

              sowmyaramesh Sowmya Ramesh
              svenkat Venkatesh Seetharam
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: