Storm 不从 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 声明为依赖项。

Storm 不从 HDFS 读取（不识别 HdfsSpout）

Storm not reading from HDFS (HdfsSpout not recognized)

apache-storm