[root@sandbox storm-demo]# sh 004-run-storm-job.sh Running: /usr/lib/jvm/java/bin/java -server -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/hdp/2.6.0.3-8/storm -Dstorm.log.dir=/var/log/storm -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /usr/hdp/2.6.0.3-8/storm/lib/storm-core-1.1.0.2.6.0.3-8.jar:/usr/hdp/2.6.0.3-8/storm/lib/slf4j-api-1.7.21.jar:/usr/hdp/2.6.0.3-8/storm/lib/zookeeper.jar:/usr/hdp/2.6.0.3-8/storm/lib/storm-rename-hack-1.1.0.2.6.0.3-8.jar:/usr/hdp/2.6.0.3-8/storm/lib/servlet-api-2.5.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-slf4j-impl-2.8.jar:/usr/hdp/2.6.0.3-8/storm/lib/asm-5.0.3.jar:/usr/hdp/2.6.0.3-8/storm/lib/clojure-1.7.0.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-over-slf4j-1.6.6.jar:/usr/hdp/2.6.0.3-8/storm/lib/objenesis-2.1.jar:/usr/hdp/2.6.0.3-8/storm/lib/reflectasm-1.10.1.jar:/usr/hdp/2.6.0.3-8/storm/lib/ring-cors-0.1.5.jar:/usr/hdp/2.6.0.3-8/storm/lib/disruptor-3.3.2.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-core-2.8.jar:/usr/hdp/2.6.0.3-8/storm/lib/kryo-3.0.3.jar:/usr/hdp/2.6.0.3-8/storm/lib/ambari-metrics-storm-sink.jar:/usr/hdp/2.6.0.3-8/storm/lib/minlog-1.3.0.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-api-2.8.jar org.apache.storm.daemon.ClientJarTransformerRunner org.apache.storm.hack.StormShadeTransformer /root/tutoriales/crosscomponent_scripts/storm-demo/lib/storm-samples-1.0-jar-with-dependencies.jar /tmp/bd704ef6b82211e78bdc0242ac110002.jar 749 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/state/StateFactory to org/apache/storm/trident/state/StateFactory in storm/kafka/trident/TridentKafkaStateFactory.class. please modify your code to use the new namespace 756 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/task/IMetricsContext to org/apache/storm/task/IMetricsContext in storm/kafka/trident/TridentKafkaStateFactory.class. please modify your code to use the new namespace 756 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/state/State to org/apache/storm/trident/state/State in storm/kafka/trident/TridentKafkaStateFactory.class. please modify your code to use the new namespace 766 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IOpaquePartitionedTridentSpout$Emitter to org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout$Emitter in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 766 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IOpaquePartitionedTridentSpout to org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 767 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IPartitionedTridentSpout$Emitter to org/apache/storm/trident/spout/IPartitionedTridentSpout$Emitter in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 767 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IPartitionedTridentSpout to org/apache/storm/trident/spout/IPartitionedTridentSpout in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 767 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/ReducedMetric to org/apache/storm/metric/api/ReducedMetric in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 767 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/CombinedMetric to org/apache/storm/metric/api/CombinedMetric in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 767 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/task/TopologyContext to org/apache/storm/task/TopologyContext in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 768 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/IMetric to org/apache/storm/metric/api/IMetric in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 769 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/MeanReducer to org/apache/storm/metric/api/MeanReducer in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 769 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/IReducer to org/apache/storm/metric/api/IReducer in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 769 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/ICombiner to org/apache/storm/metric/api/ICombiner in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 770 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/topology/TransactionAttempt to org/apache/storm/trident/topology/TransactionAttempt in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 770 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/operation/TridentCollector to org/apache/storm/trident/operation/TridentCollector in storm/kafka/trident/TridentKafkaEmitter.class. please modify your code to use the new namespace 784 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IOpaquePartitionedTridentSpout$Coordinator to org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout$Coordinator in storm/kafka/trident/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace 785 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/tuple/Fields to org/apache/storm/tuple/Fields in storm/kafka/trident/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace 785 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/spout/MultiScheme to org/apache/storm/spout/MultiScheme in storm/kafka/trident/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace 786 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/state/BaseStateUpdater to org/apache/storm/trident/state/BaseStateUpdater in storm/kafka/trident/TridentKafkaUpdater.class. please modify your code to use the new namespace 787 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/tuple/TridentTuple to org/apache/storm/trident/tuple/TridentTuple in storm/kafka/trident/TridentKafkaUpdater.class. please modify your code to use the new namespace 792 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/ISpoutPartition to org/apache/storm/trident/spout/ISpoutPartition in storm/kafka/trident/TridentKafkaEmitter$1.class. please modify your code to use the new namespace 794 [main] WARN o.a.s.h.DefaultShader - Relocating storm/trident/spout/IPartitionedTridentSpout$Coordinator to org/apache/storm/trident/spout/IPartitionedTridentSpout$Coordinator in storm/kafka/trident/TransactionalTridentKafkaSpout.class. please modify your code to use the new namespace 802 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/task/OutputCollector to org/apache/storm/task/OutputCollector in storm/kafka/trident/TridentKafkaState.class. please modify your code to use the new namespace 805 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/FailedException to org/apache/storm/topology/FailedException in storm/kafka/trident/TridentKafkaState.class. please modify your code to use the new namespace 819 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/tuple/Values to org/apache/storm/tuple/Values in storm/kafka/StringKeyValueScheme.class. please modify your code to use the new namespace 822 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/utils/Utils to org/apache/storm/utils/Utils in storm/kafka/ZkState.class. please modify your code to use the new namespace 826 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/spout/SpoutOutputCollector to org/apache/storm/spout/SpoutOutputCollector in storm/kafka/KafkaSpout$2.class. please modify your code to use the new namespace 829 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/tuple/Tuple to org/apache/storm/tuple/Tuple in storm/kafka/bolt/mapper/FieldNameBasedTupleToKafkaMapper.class. please modify your code to use the new namespace 831 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/base/BaseRichBolt to org/apache/storm/topology/base/BaseRichBolt in storm/kafka/bolt/KafkaBolt.class. please modify your code to use the new namespace 832 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/utils/TupleUtils to org/apache/storm/utils/TupleUtils in storm/kafka/bolt/KafkaBolt.class. please modify your code to use the new namespace 833 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/OutputFieldsDeclarer to org/apache/storm/topology/OutputFieldsDeclarer in storm/kafka/bolt/KafkaBolt.class. please modify your code to use the new namespace 839 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/spout/Scheme to org/apache/storm/spout/Scheme in storm/kafka/KeyValueScheme.class. please modify your code to use the new namespace 857 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/base/BaseRichSpout to org/apache/storm/topology/base/BaseRichSpout in storm/kafka/KafkaSpout.class. please modify your code to use the new namespace 864 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/spout/RawMultiScheme to org/apache/storm/spout/RawMultiScheme in storm/kafka/KafkaConfig.class. please modify your code to use the new namespace 867 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/spout/SchemeAsMultiScheme to org/apache/storm/spout/SchemeAsMultiScheme in storm/kafka/KeyValueSchemeAsMultiScheme.class. please modify your code to use the new namespace 882 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/metric/api/CountMetric to org/apache/storm/metric/api/CountMetric in storm/kafka/PartitionManager.class. please modify your code to use the new namespace 2802 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/security/auth/IAutoCredentials to org/apache/storm/security/auth/IAutoCredentials in org/apache/storm/hdfs/common/security/AutoHDFS.class. please modify your code to use the new namespace 2802 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/security/auth/ICredentialsRenewer to org/apache/storm/security/auth/ICredentialsRenewer in org/apache/storm/hdfs/common/security/AutoHDFS.class. please modify your code to use the new namespace 2802 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/security/INimbusCredentialPlugin to org/apache/storm/security/INimbusCredentialPlugin in org/apache/storm/hdfs/common/security/AutoHDFS.class. please modify your code to use the new namespace 2804 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/security/auth/kerberos/AutoTGT to org/apache/storm/security/auth/kerberos/AutoTGT in org/apache/storm/hdfs/common/security/HdfsSecurityUtil.class. please modify your code to use the new namespace 2809 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/Config to org/apache/storm/Config in org/apache/storm/hdfs/bolt/AbstractHdfsBolt.class. please modify your code to use the new namespace 2814 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/codedistributor/ICodeDistributor to org/apache/storm/codedistributor/ICodeDistributor in org/apache/storm/hdfs/ha/codedistributor/HDFSCodeDistributor.class. please modify your code to use the new namespace 30823 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/base/BaseBasicBolt to org/apache/storm/topology/base/BaseBasicBolt in com/dsinpractice/storm/samples/WordCountTopology$JavaSplitSentence.class. please modify your code to use the new namespace 30823 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/BasicOutputCollector to org/apache/storm/topology/BasicOutputCollector in com/dsinpractice/storm/samples/WordCountTopology$JavaSplitSentence.class. please modify your code to use the new namespace 30824 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/TopologyBuilder to org/apache/storm/topology/TopologyBuilder in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30825 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/generated/StormTopology to org/apache/storm/generated/StormTopology in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30825 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/StormSubmitter to org/apache/storm/StormSubmitter in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30825 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/IRichSpout to org/apache/storm/topology/IRichSpout in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30825 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/SpoutDeclarer to org/apache/storm/topology/SpoutDeclarer in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30825 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/IBasicBolt to org/apache/storm/topology/IBasicBolt in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30826 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/BoltDeclarer to org/apache/storm/topology/BoltDeclarer in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30826 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/InputDeclarer to org/apache/storm/topology/InputDeclarer in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30826 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/IRichBolt to org/apache/storm/topology/IRichBolt in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30826 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/generated/AlreadyAliveException to org/apache/storm/generated/AlreadyAliveException in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30827 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/generated/InvalidTopologyException to org/apache/storm/generated/InvalidTopologyException in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30827 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/Testing to org/apache/storm/Testing in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace 30827 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/ILocalCluster to org/apache/storm/ILocalCluster in com/dsinpractice/storm/samples/WordCountTopology.class. please modify your code to use the new namespace Running: /usr/lib/jvm/java/bin/java -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/hdp/2.6.0.3-8/storm -Dstorm.log.dir=/var/log/storm -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib:/usr/hdp/current/storm-client/lib -Dstorm.conf.file= -cp /usr/hdp/2.6.0.3-8/storm/lib/storm-core-1.1.0.2.6.0.3-8.jar:/usr/hdp/2.6.0.3-8/storm/lib/slf4j-api-1.7.21.jar:/usr/hdp/2.6.0.3-8/storm/lib/zookeeper.jar:/usr/hdp/2.6.0.3-8/storm/lib/storm-rename-hack-1.1.0.2.6.0.3-8.jar:/usr/hdp/2.6.0.3-8/storm/lib/servlet-api-2.5.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-slf4j-impl-2.8.jar:/usr/hdp/2.6.0.3-8/storm/lib/asm-5.0.3.jar:/usr/hdp/2.6.0.3-8/storm/lib/clojure-1.7.0.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-over-slf4j-1.6.6.jar:/usr/hdp/2.6.0.3-8/storm/lib/objenesis-2.1.jar:/usr/hdp/2.6.0.3-8/storm/lib/reflectasm-1.10.1.jar:/usr/hdp/2.6.0.3-8/storm/lib/ring-cors-0.1.5.jar:/usr/hdp/2.6.0.3-8/storm/lib/disruptor-3.3.2.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-core-2.8.jar:/usr/hdp/2.6.0.3-8/storm/lib/kryo-3.0.3.jar:/usr/hdp/2.6.0.3-8/storm/lib/ambari-metrics-storm-sink.jar:/usr/hdp/2.6.0.3-8/storm/lib/minlog-1.3.0.jar:/usr/hdp/2.6.0.3-8/storm/lib/log4j-api-2.8.jar:/tmp/bd704ef6b82211e78bdc0242ac110002.jar:/usr/hdp/current/storm-supervisor/conf:/usr/hdp/2.6.0.3-8/storm/bin -Dstorm.jar=/tmp/bd704ef6b82211e78bdc0242ac110002.jar -Dstorm.dependency.jars= -Dstorm.dependency.artifacts={} com.dsinpractice.storm.samples.WordCountTopology --cluster true --name storm-demo-topology-02 --path /user/storm/storm-hdfs-test-01 --topic my-topic-01 1089 [main] INFO o.a.s.h.b.AbstractHdfsBolt - Enabling tick tuple with interval [1] 1455 [main] INFO o.a.s.StormSubmitter - Generated ZooKeeper secret payload for MD5-digest: -5065022617956381043:-4983315084217890390 1586 [main] INFO o.a.s.u.NimbusClient - Found leader nimbus : sandbox.hortonworks.com:6627 1609 [main] INFO o.a.s.s.a.AuthUtils - Got AutoCreds [] 1616 [main] INFO o.a.s.u.NimbusClient - Found leader nimbus : sandbox.hortonworks.com:6627 1640 [main] INFO o.a.s.StormSubmitter - Uploading dependencies - jars... 1649 [main] INFO o.a.s.StormSubmitter - Uploading dependencies - artifacts... 1649 [main] INFO o.a.s.StormSubmitter - Dependency Blob keys - jars : [] / artifacts : [] 1655 [main] INFO o.a.s.StormSubmitter - Uploading topology jar /tmp/bd704ef6b82211e78bdc0242ac110002.jar to assigned location: /hadoop/storm/nimbus/inbox/stormjar-e32b6db1-916a-46b1-8b51-4627ef5fecb0.jar 2337 [main] INFO o.a.s.StormSubmitter - Successfully uploaded topology jar to assigned location: /hadoop/storm/nimbus/inbox/stormjar-e32b6db1-916a-46b1-8b51-4627ef5fecb0.jar 2337 [main] INFO o.a.s.StormSubmitter - Submitting topology storm-demo-topology-02 in distributed mode with conf {"storm.zookeeper.topology.auth.scheme":"digest","storm.zookeeper.topology.auth.payload":"-5065022617956381043:-4983315084217890390","topology.workers":3,"topology.debug":true} 3105 [main] INFO o.a.s.StormSubmitter - Finished submitting topology: storm-demo-topology-02 3106 [main] INFO o.a.s.StormSubmitter - Initializing the registered ISubmitterHook [org.apache.atlas.storm.hook.StormAtlasHook] 3106 [main] WARN o.a.s.StormSubmitter - Error occurred in invoking submitter hook:[org.apache.atlas.storm.hook.StormAtlasHook] java.lang.ClassNotFoundException: org.apache.atlas.storm.hook.StormAtlasHook at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[?:1.8.0_131] at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_131] at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) ~[?:1.8.0_131] at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_131] at java.lang.Class.forName0(Native Method) ~[?:1.8.0_131] at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_131] at org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:361) [storm-core-1.1.0.2.6.0.3-8.jar:1.1.0.2.6.0.3-8] at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:278) [storm-core-1.1.0.2.6.0.3-8.jar:1.1.0.2.6.0.3-8] at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:390) [storm-core-1.1.0.2.6.0.3-8.jar:1.1.0.2.6.0.3-8] at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:162) [storm-core-1.1.0.2.6.0.3-8.jar:1.1.0.2.6.0.3-8] at com.dsinpractice.storm.samples.WordCountTopology.main(WordCountTopology.java:140) [bd704ef6b82211e78bdc0242ac110002.jar:?] Exception in thread "main" org.apache.storm.hooks.SubmitterHookException: java.lang.ClassNotFoundException: org.apache.atlas.storm.hook.StormAtlasHook at org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:368) at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:278) at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:390) at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:162) at com.dsinpractice.storm.samples.WordCountTopology.main(WordCountTopology.java:140) Caused by: java.lang.ClassNotFoundException: org.apache.atlas.storm.hook.StormAtlasHook at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:361) ... 4 more