2016-06-01 15 views
1

Ich spring-XD-1.3.1.RELEASE Run-Time-Container, wenn ich versuchte, Moduldatei mit der Quelle von ftp zu hdfs, Ich bekomme eine Ausnahme in dem Shell-Befehl, der unten angegeben ist.Spring XD - Modul mit dem Namen 'ftphdfs' nicht gefunden und 'Quelle' eingeben

Auch wenn ich versuchte, Quelle als HTTP-Endpunkt zu verwenden, erhalte ich eine Ausnahme wie diese in Shell-Befehl, der unten angegeben ist.

    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 

Tech-Stack, die ich zur Zeit verwendet, ist unten angegeben.
1) Hadoop 2.7.2
2) Frühlings-XD-1.3.1.RELEASE
3) Redis 2.6 (Windows-Version) - ich dies als Transport verwenden
4) Zoo-Keeper 3.8

Jede Hilfe wäre willkommen.

Antwort

3

Es ist ein job kein Strom source ...

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

Ich habe nicht eine Ausnahme für source:http oben sehen - nur eine Beschreibung der Quelle.