风暴未从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

我猜你在类路径上没有风暴hdfs。检查您的 pom(或您使用的任何依赖项管理系统的等效项(，并确保将 storm-hdfs 声明为依赖项。