[jira] [Commented] (ATLAS-1333) Storm Hook fails to capture the topology

["Shwetha G S (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/ATLAS-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15700987#comment-15700987 ] 

Shwetha G S commented on ATLAS-1333:
------------------------------------

+1

> Storm Hook fails to capture the topology
> ----------------------------------------
>
>                 Key: ATLAS-1333
>                 URL: https://issues.apache.org/jira/browse/ATLAS-1333
>             Project: Atlas
>          Issue Type: Bug
>            Reporter: Vimal Sharma
>            Assignee: Vimal Sharma
>             Fix For: 0.8-incubating
>
>         Attachments: ATLAS-1333.patch
>
>
> Storm hook does not capture the submitted topology. There is a conflict in the different versions of JSON4s libraries which are pulled in. Further, Storm IT is failing due to non registry of storm_topology type at the time of Atlas bootstrap.
> Below is the error when a topology is submit:
> 4865 [main] INFO  o.a.a.h.AtlasHook - Adding entity for type: storm_topology
> Exception in thread "main" java.lang.NoSuchMethodError: scala.collection.immutable.$colon$colon.hd$1()Ljava/lang/Object;
> 	at org.json4s.MonadicJValue.$bslash(MonadicJValue.scala:18)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$14.apply(Extraction.scala:482)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$14.apply(Extraction.scala:482)
> 	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> 	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> 	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> 	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> 	at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> 	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 	at org.json4s.Extraction$ClassInstanceBuilder.org$json4s$Extraction$ClassInstanceBuilder$$instantiate(Extraction.scala:470)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$6.apply(Extraction.scala:515)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$6.apply(Extraction.scala:512)
> 	at org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:524)
> 	at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:512)
> 	at org.json4s.Extraction$.extract(Extraction.scala:351)
> 	at org.json4s.Extraction$ClassInstanceBuilder.org$json4s$Extraction$ClassInstanceBuilder$$mkWithTypeHint(Extraction.scala:507)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$6.apply(Extraction.scala:514)
> 	at org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$6.apply(Extraction.scala:512)
> 	at org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:524)
> 	at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:512)
> 	at org.json4s.Extraction$.extract(Extraction.scala:351)
> 	at org.json4s.Extraction$.extract(Extraction.scala:42)
> 	at org.json4s.ExtractableJsonAstNode.extract(ExtractableJsonAstNode.scala:21)
> 	at org.json4s.native.Serialization$.read(Serialization.scala:71)
> 	at org.apache.atlas.typesystem.json.InstanceSerialization$.fromJsonReferenceable(InstanceSerialization.scala:371)
> 	at org.apache.atlas.typesystem.json.InstanceSerialization.fromJsonReferenceable(InstanceSerialization.scala)
> 	at org.apache.atlas.notification.hook.HookNotification$EntityCreateRequest.<init>(HookNotification.java:152)
> 	at org.apache.atlas.hook.AtlasHook.notifyEntities(AtlasHook.java:100)
> 	at org.apache.atlas.storm.hook.StormAtlasHook.notify(StormAtlasHook.java:102)
> 	at org.apache.atlas.storm.hook.StormAtlasHook.notify(StormAtlasHook.java:57)
> 	at org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:358)
> 	at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:273)
> 	at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:384)
> 	at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:161)
> 	at storm.starter.WordCountTopology.main(WordCountTopology.java:77)



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