0

これは、AWS インスタンスのコンソールに表示されるエラーです。

2014-08-09 12:22:41,803 (lifecycleSupervisor-1-2) [INFO -org.apache.flume.source.AvroSource.start(AvroSource.java:142)] ローカルからの Avro ソースの開始: { bindAddress: ec2-54 -221-143-114.compute-1.amazonaws.com、ポート: 44444}... 2014-08-09 12:22:42,072 (lifecycleSupervisor-1-1) [警告 - org.apache.flume.sink. AvroSink.start(AvroSink.java:244)] ホスト名を使用して avro クライアントを作成できません: ec2-54-221-143-114.compute-1.amazonaws.com、ポート: 41414 org.apache.flume.FlumeException: NettyAvroRpcClient {ホスト: ec2-54-221-143-114.compute-1.amazonaws.com、ポート: 41414 }: org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:117) での org での RPC 接続エラー。 org.apache.flume.api.NettyAvroRpcClient の apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:93)。configure(NettyAvroRpcClient.java:514) org.apache.flume.api.RpcClientFactory.getInstance(RpcClientFactory.java:88) org.apache.flume.sink.AvroSink.createConnection(AvroSink.java:182) org.apache org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46) の .flume.sink.AvroSink.start(AvroSink.java:242) org.apache.flume.SinkRunner.start(SinkRunner.java:79) の) org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:236) で java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) で java.util.concurrent.FutureTask で。 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) java.util.concurrent.ThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) で java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) で(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) 原因: java.io.IOException: ec2-54-221-143-114.compute-1.amazonaws への接続エラー。 com/10.80.54.114:41414 at org.apache.avro.ipc.NettyTransceiver.getChannel(NettyTransceiver.java:261) at org.apache.avro.ipc.NettyTransceiver.(NettyTransceiver.java:203) at org.apache.avro .ipc.NettyTransceiver.(NettyTransceiver.java:152) at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:106) ...15 以上 原因: java.net.ConnectException: org.jboss.netty で sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) で接続が拒否されました.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:401) org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:370) org.jboss.netty .channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:292)739) org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:401) で org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java: 370) org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:292) で739) org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:401) で org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java: 370) org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:292) で

4

1 に答える 1

0

最初にローカル マシンで Avro Source を使用して Flume エージェントを実行し、次に Avro シンクを使用して Flume エージェントを実行します。その理由は、Avro Source が特定の IP とポートにバインドされた Avro RPC サーバーを起動するためです。Avro Sink は、Avro RPC サーバーをリッスンし、flume イベントを送信する avro rpc クライアントです。

于 2015-05-27T10:02:44.137 に答える