flume 启动报错

 如下：

java.lang.NumberFormatException: For input string: "44444 "
at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
at java.lang.Integer.parseInt(Integer.java:580)
at java.lang.Integer.parseInt(Integer.java:615)
at org.apache.flume.Context.getInteger(Context.java:162)
at org.apache.flume.Context.getInteger(Context.java:180)
at org.apache.flume.source.NetcatSource.configure(NetcatSource.java:140)
at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
at org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:326)
at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:97)

我配置的文件如下：

a1.sources=r1
a1.channels=c1
a1.sinks=s1

a1.sources.r1.type=netcat
a1.sources.r1.bind=0.0.0.0
a1.sources.r1.port=44444 
#描述a1的s1
a1.sinks.s1.type=logger
 

仔细看了很多遍，没错呀

最终发现是4444后面多了一个空格，这才导致识别成string

最后

以上就是香蕉秋天为你收集整理的flume 启动报错的全部内容，希望文章能够帮你解决flume 启动报错所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。