Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor

Question

这是我的配置

启动命令
flume-ng agent --name simple-agent --conf $FLUME_HOME/conf --conf-file $FLUME_HOME/conf/flume_pull_streaming.conf -Dflume.root.logger=INFO,console

启动报错
2020-09-01 11:36:32,691 (lifecycleSupervisor-1-2) [INFO - org.apache.flume.source.NetcatSource.start(NetcatSource.java:169)] Created serverSocket:sun.nio.ch.ServerSocketChannelImpl[/192.168.110.197:44444]
2020-09-01 11:36:32,895 (lifecycleSupervisor-1-1) [ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:253)]UnabletostartSinkRunner:policy:org.apache.flume.sink.DefaultSinkProcessor@4172e9eacounterGroup:name:nullcounters:-Exceptionfollows.org.jboss.netty.channel.ChannelException:Failedtobindto:/192.168.110.146:41414atorg.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272)atorg.apache.avro.ipc.NettyServer.<init>(NettyServer.java:106)atorg.apache.avro.ipc.NettyServer.<init>(NettyServer.java:119)atorg.apache.avro.ipc.NettyServer.<init>(NettyServer.java:74)atorg.apache.avro.ipc.NettyServer.<init>(NettyServer.java:68)atorg.apache.spark.streaming.flume.sink.SparkSink.start(SparkSink.scala:90)atorg.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46)atorg.apache.flume.SinkRunner.start(SinkRunner.java:79)atorg.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)atjava.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)atjava.lang.Thread.run(Thread.java:748)Causedby:java.net.BindException:Cannotassignrequestedaddressatsun.nio.ch.Net.bind0(NativeMethod)atsun.nio.ch.Net.bind(Net.java:433)atsun.nio.ch.Net.bind(Net.java:425)atsun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)atsun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)atorg.jboss.netty.channel.socket.nio.NioServerBoss$RegisterTask.run(NioServerBoss.java:193)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:366)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:290)
at org.jboss.netty.channel.

Answer 1

提问者 ABC简简简简 2020-09-01 11:39:12

[ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:253)] Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@4172e9ea counterGroup:{ name:null counters:{} } } - Exception follows.

org.jboss.netty.channel.ChannelException: Failed to bind to: /192.168.110.146:41414

无法启动sink ？有么有遇到相同问题的同学

• Michael_PK #1

  你这个要注意下启动顺序，41414这个应该是下游的端口吧

• 提问者 ABC简简简简 回复 Michael_PK #2

  [ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:253)] Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@7d9b0a35 counterGroup:{ name:null counters:{} } } - Exception follows.
  
  org.jboss.netty.channel.ChannelException: Failed to bind to: /192.168.110.146:41414
  
  Caused by: java.net.BindException: Cannot assign requested address
  
  
  使用pull方式整合时，应先启动flume、再启动spark app。顺序应是没问题的。

• Michael_PK 回复 提问者 ABC简简简简 #3

  你听下视频，哪个先启动，都有讲的，按照视频中我是先干啥的你也跟着干啥

点开查看后面4条评论