jacky
启动flume时
flume-ngagent\
--nameflume-avro-agent\
--conf$FLUME_HOME/conf\
--conf-file$FLUME_HOME/config/***.conf\
-dflume.***.lo多gger=INFO,console
2017-11-1214:49:36,684(SinkRun来自ner-PollingRunner-DefaultSinkProcessor)[INFO-org.***.sink.abstractrpcsink.createconnection(***.java:205)]Rpcsinkavro-sink:BuildingRpcClientwit360问答hhostname:nod汽促粒e,port:44444
2017-11-1214:49:36,687(SinkRunner-PollingRunner-DefaultSinkProcessor)[INFO-org.***.sink.avrosink.initializerpcclient(***.java:126)]AttemptingtocreateAvroRpcclient.
2017-11-12温移的道多称水电联14:49:36,689(SinkRunner-PollingRunner-DefaultSinkProcessor)[WARN-org.***.api.nettyavrorpcclient.configure(***.java:634)]UsingdefaultmaxIOWorkers
2017-11-1214:49:36,732(SinkRunner-P济ollingRun金两磁罪晶试赶么皮呢川ner-Defa哥脱配没绍带负氢映ultSinkProcessor)[ERROR-org.***.sinkrunner$***.run(***.java:158)]Unable很todeliver排头冲简础event.Exceptionfollows.
org.***.event校府地deliveryexception:Failedtosendeve谈劳巴取nts
atorg.医作头冷省克手计听斤丰***.sink.abst倒角认正己欢外倒石天ractrpcsink.process(***.java:389)
atorg.***.sink.defaultsinkproce资胶查非染命缩运浓乎ssor.process(***.java:67)
atorg.***既济收富比.sinkrun阳兰正拿做帮思景水晚正ner$***.run丰棉矿得元(***.java:145)
atjava.**造护两起困刑效*.run(***.java:令由江备745)
Causedby:org.***.flumeexception:NettyAvroRpcClient{host:node,port:44444}:RPCconnectionerror
atorg.***.api.nettyavrorpcclient.connect(***.java:181)
atorg.***.api.nettyavrorpcclient.connect(***.java:120)
atorg.***.api.nettyavrorpcclient.configure(***.java:638)
atorg.***.api.rpcclientfactory.getinstance(***.java:90)
atorg.***.sink.avrosink.initializerpcclient(***.java:127)
atorg.***.sink.abstractrpcsink.createconnection(***.java:210)
atorg.***.sink.abstractrpcsink.verifyconnection(***.java:270)
atorg.***.sink.abstractrpcsink.process(***.java:346)
...3more
Causedby:java.***.***except***n:Errorconnectingtonode/192.168.47.6:44444
atorg.***.ipc.nettytransceiver.getChannel(***.java:261)
atorg.***.ipc.nettytransceiver.
atorg.***.ipc.nettytransceiver.
atorg.***.api.nettyavrorpcclient.connect(***.java:169)
...10more
Causedby:java.***.connectexception:拒绝连接:node/192.168.47.6:44444
atsun.***.socketchannelimpl.checkconnect(NativeMethod)
atsun.***.socketchannelimpl.finishconnect(***.java:717)
atorg.***.channel.socket.nio.nioclientboss.connect(***.java:152)
atorg.***.channel.socket.nio.nioclientboss.processSelectedKeys(***.java:105)
atorg.***.channel.socket.nio.nioclientboss.process(***.java:79)
atorg.***.channel.socket.nio.abstractnioselector.run(***.java:318)
atorg.***.channel.socket.nio.nioclientboss.run(***.java:42)
atorg.***.util.threadrenamingrunnable.run(***.java:108)
atorg.***.util.internal.deadlockproofworker$1.run(***.java:42)
atjava.***.threadpoolexecutor.runWorker(***.java:1142)
atjava.***.threadpoolexecutor$***.run(***.java:617)
...1more
