Запускает Apache Flume во встроенном режиме - PullRequest
Новая
       8

Запускает Apache Flume во встроенном режиме

0 голосов
/ 29 октября 2018

Я новичок в плавании.Я пытаюсь запустить его в приложении как «Все в одном», но не могу понять, что не так.Не могли бы вы помочь?Он не может подключиться к локальному хосту. Исходный код 

2018-10-28 23:57:59,757+0200] [INFO ] [AvroSink] (main:) Attempting to create Avro Rpc client.
[2018-10-28 23:57:59,777+0200] [WARN ] [NettyAvroRpcClient] (main:) Using default maxIOWorkers
[2018-10-28 23:58:01,057+0200] [WARN ] [AbstractRpcSink] (main:) Unable to create Rpc client using hostname: pc0039, port: 44444
org.apache.flume.FlumeException: NettyAvroRpcClient { host: pc0039, port: 44444 }: RPC connection error at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:181)
    at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:120)
    at org.apache.flume.api.NettyAvroRpcClient.configure(NettyAvroRpcClient.java:638)
    at org.apache.flume.api.RpcClientFactory.getInstance(RpcClientFactory.java:90)
    at org.apache.flume.sink.AvroSink.initializeRpcClient(AvroSink.java:127)
    at org.apache.flume.sink.AbstractRpcSink.createConnection(AbstractRpcSink.java:210)
    at org.apache.flume.sink.AbstractRpcSink.start(AbstractRpcSink.java:290)
    at org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:45)
    at org.apache.flume.SinkRunner.start(SinkRunner.java:79)
    at org.apache.flume.agent.embedded.EmbeddedAgent.doStart(EmbeddedAgent.java:224)
    at org.apache.flume.agent.embedded.EmbeddedAgent.start(EmbeddedAgent.java:127)
    at com.com.test.flume.Program.createAgent(Program.java:97)
    at com.com.test.flume.Program.main(Program.java:65)
Caused by: java.io.IOException: Error connecting to pc0039/192.168.0.103:44444
    at org.apache.avro.ipc.NettyTransceiver.getChannel(NettyTransceiver.java:261)
    at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:203)
    at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:152)
    at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:169)
    ... 12 more
Caused by: java.net.ConnectException: Connection refused: no further information: pc0039/192.168.0.103:44444
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:152)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:79)
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
    at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
    at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
...