Spring XD - 找不到名称为 'ftphdfs' 且类型为 'source' 的模块



我运行spring-xd-1.3.1.RELEASE运行时容器,当我尝试使用从ftp到hdfs的源代码模块文件时,我在下面给出的shell命令中出现异常。

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 端点时,我在下面给出的 shell 命令中出现这样的异常。

                    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.发布
3) Redis 2.6 (Windows 版本) - 我使用它作为传输
4) 动物园管理员 3.8

任何帮助将不胜感激。

这是一个

job而不是一个流source...

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

我没有看到上述source:http例外 - 只是对来源的描述。

相关内容

最新更新