Spring XD - Не удалось найти модуль с именем 'ftphdfs' и введите 'source'

Question

Я запускаю контейнер run-time spring-xd-1.3.1.RELEASE, когда я попытался подключиться к файлу модуля с источником из ftp в hdfs, Я получаю исключение в команде оболочки, которая приведена ниже.

xd:>module info --name source:ftphdfs 
    Command failed org.springframework.xd.rest.client.impl.SpringXDException: Could 
    not find module with name 'ftphdfs' and type 'source' 

Также, когда я пытался использовать источник в качестве конечной точки http, я получаю исключение, подобное этому в команде оболочки, которая приведена ниже.

    xd:>module info --name source:http 
          Information about source module 'http': 
          Injects data from http endpoint. 

           Option Name   Description 

             Default 
          Type 
           --------------------- ------------------------------------------------------- 
          -------------------------------------------------------------------------------- 
          --------- ------------------------------------------------------------------- 
          --------------------------------- 
           https     true for https:// 

             false 
          boolean 
           maxContentLength  the maximum allowed content length 

             1048576 
          int 
           messageConverterClass the name of a custom MessageConverter class, to convert 
          HttpRequest to Message; must have a constructor with a 'MessageBuilderFactory' 
          parameter org.springframework.integration.x.http.NettyInboundMessageConverter 
          java.lang.String 
           port     the port to listen to 

             9000 
          int 
           sslPropertiesLocation location (resource) of properties containing the locati 
          on of the pkcs12 keyStore and pass phrase 
             classpath:httpSSL.properties 
          java.lang.String 
           outputType    how this module should emit messages it produces 

             <none> 
          org.springframework.util.MimeType 

Технология стека, который я в настоящее время использую приводится ниже.
1) Hadoop 2.7.2
2) Спринг-XD-1.3.1.RELEASE
3) Redis 2.6 (Версия Windows) - Я использую это как транспорт
4) Зоопарк-хранитель 3.8

Любая помощь будет оценена по достоинству.

Answer 1

Это job не поток source ...

xd:>module info job:ftphdfs 
Information about job module 'ftphdfs': 
... 

Я не вижу исключение для source:http выше - просто описание источника.