风暴没有从HDFS读取（HdfsSpout无法识别）

Question

我使用风暴1.0.x，但当我尝试使用下面的

// Instantiate spout to read text files
        HdfsSpout textReaderSpout = newHdfsSpout().setReaderType("text")
                                                  .withOutputFields(TextFileReader.defaultFields)
                                                  .setHdfsUri("hdfs://localhost:54310")  // reqd
                                                  .setSourceDir("/data/in")              // reqd
                                                  .setArchiveDir("/data/done")           // reqd
                                                  .setBadFilesDir("/data/badfiles");     // required

我得到HdfsSpout cannot be resolved to a type

特定版本中是否提供此功能或可能是什么问题？

Answer 1

我猜你在类路径上没有storm-hdfs。检查你的pom（或你使用的任何依赖管理系统的等价物），并确保storm-hdfs被声明为依赖。