当我运行包含Hbase Bolt的Storm拓扑时,我有以下错误.
java.io.IOException: No FileSystem for scheme: hdfs at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2298) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2305) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:89) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2344) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2326) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:353) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.fs.Path.getFileSystem(Path.java:194) ~[hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.hadoop.hbase.util.DynamicClassLoader.(DynamicClassLoader.java:104) ~[hbase-common-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.protobuf.ProtobufUtil. (ProtobufUtil.java:201) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.ClusterId.parseFrom(ClusterId.java:64) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.zookeeper.ZKClusterId.readClusterIdZNode(ZKClusterId.java:69) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.ZooKeeperRegistry.getClusterId(ZooKeeperRegistry.java:83) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.retrieveClusterId(HConnectionManager.java:857) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation. (HConnectionManager.java:662) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) [na:1.7.0_72] at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) [na:1.7.0_72] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) [na:1.7.0_72] at java.lang.reflect.Constructor.newInstance(Constructor.java:526) [na:1.7.0_72] at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:414) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:393) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HConnectionManager.getConnection(HConnectionManager.java:274) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HTable. (HTable.java:194) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.hadoop.hbase.client.HTable. (HTable.java:156) [hbase-client-0.98.1-hadoop2.jar:0.98.1-hadoop2] at org.apache.storm.hbase.bolt.HBaseBolt$1.run(HBaseBolt.java:97) [storm-hbase-0.1.2.jar:na] at org.apache.storm.hbase.bolt.HBaseBolt$1.run(HBaseBolt.java:94) [storm-hbase-0.1.2.jar:na] at java.security.AccessController.doPrivileged(Native Method) [na:1.7.0_72] at javax.security.auth.Subject.doAs(Subject.java:415) [na:1.7.0_72] at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1438) [hadoop-common-2.0.0-cdh4.7.0.jar:na] at org.apache.storm.hbase.bolt.HBaseBolt.prepare(HBaseBolt.java:94) [storm-hbase-0.1.2.jar:na] at backtype.storm.daemon.executor$fn__3352$fn__3364.invoke(executor.clj:690) [storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.util$async_loop$fn__452.invoke(util.clj:429) [storm-core-0.9.2-incubating.jar:0.9.2-incubating] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_72]
16:44:32.839 [Thread-31-HbasePersistorBolt] INFO backtype.storm.daemon.executor - 准备好的螺栓HbasePersistorBolt:(5)
这是我的pom.xml
http://maven.apache.org/xsd/maven-4.0.0.xsd"> aid-cim fr.aid.cim 0.9-SNAPSHOT 4.0.0 event-struct-topology
org.apache.hadoop hadoop-client ${org.apache.hadoop.version} com.google.protobuf protobuf-java com.google.protobuf protobuf-java 2.5.0 com.github.ptgoetz storm-hbase ${storm-hbase.version} org.apache.storm storm-kafka 0.9.2-incubating org.apache.kafka kafka_2.10 0.8.1.1 org.apache.zookeeper zookeeper log4j log4j fr.aid.cim commons ${project.version} fr.aid.cim storm-hazelcast ${project.version} org.apache.hadoop hadoop-core test org.apache.hadoop hadoop-common test-jar test org.apache.hbase hbase ${org.apache.hbase.version} test-jar test org.apache.hadoop hadoop-hdfs ${org.apache.hadoop.version} test-jar test org.apache.hadoop hadoop-hdfs ${org.apache.hadoop.version} test org.apache.zookeeper zookeeper test org.json json 20140107 com.google.guava guava 11.0 com.fasterxml.jackson.core jackson-databind maven-assembly-plugin jar-with-dependencies make-assembly package single org.apache.maven.plugins maven-dependency-plugin local true org.apache.storm storm-core org.apache.zookeeper zookeeper cluster org.apache.storm storm-core provided org.apache.zookeeper zookeeper provided
有任何想法吗 ?谢谢