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

来源：9-7 -Pull方式整合之概述

ABC简简简简

2020-09-01

图片描述
这是我的配置

启动命令
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)] 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 at org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272) at org.apache.avro.ipc.NettyServer.<init>(NettyServer.java:106) at org.apache.avro.ipc.NettyServer.<init>(NettyServer.java:119) at org.apache.avro.ipc.NettyServer.<init>(NettyServer.java:74) at org.apache.avro.ipc.NettyServer.<init>(NettyServer.java:68) at org.apache.spark.streaming.flume.sink.SparkSink.start(SparkSink.scala:90) at org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46) at org.apache.flume.SinkRunner.start(SinkRunner.java:79) at org.apache.flume.lifecycle.LifecycleSupervisor$ MonitorRunnable.run(LifecycleSupervisor.java:251)
at java.util.concurrent.Executors $R u n n a b l e A d a p t e r . c a l l (E x e c u t o r s . j a v a : 511) a t j a v a . u t i l . c o n c u r r e n t . F u t u r e T a s k . r u n A n d R e s e t (F u t u r e T a s k . j a v a : 308) a t j a v a . u t i l . c o n c u r r e n t . S c h e d u l e d T h r e a d P o o l E x e c u t o r$ ScheduledFutureTask.access $301 (S c h e d u l e d T h r e a d P o o l E x e c u t o r . j a v a : 180) a t j a v a . u t i l . c o n c u r r e n t . S c h e d u l e d T h r e a d P o o l E x e c u t o r$ ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor $W o r k e r . r u n (T h r e a d P o o l E x e c u t o r . j a v a : 624) a t j a v a . l a n g . T h r e a d . r u n (T h r e a d . j a v a : 748) C a u s e d b y : j a v a . n e t . B i n d E x c e p t i o n : C a n n o t a s s i g n r e q u e s t e d a d d r e s s a t s u n . n i o . c h . N e t . b i n d 0 (N a t i v e M e t h o d) a t s u n . n i o . c h . N e t . b i n d (N e t . j a v a : 433) a t s u n . n i o . c h . N e t . b i n d (N e t . j a v a : 425) a t s u n . n i o . c h . S e r v e r S o c k e t C h a n n e l I m p l . b i n d (S e r v e r S o c k e t C h a n n e l I m p l . j a v a : 223) a t s u n . n i o . c h . S e r v e r S o c k e t A d a p t o r . b i n d (S e r v e r S o c k e t A d a p t o r . j a v a : 74) a t o r g . j b o s s . n e t t y . c h a n n e l . s o c k e t . n i o . N i o S e r v e r B o s s$ 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.

写回答

1回答

ABC简简简简

提问者

2020-09-01

[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

ABC简简简简

你先查看你这个端口，先给他干掉，然后重来

2020-09-01

共7条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程

相似问题