私はフルームに問題があります。私はビッグデータを取得しようとしているため、「ダミー用」の本のチュートリアルを使用しています。これまでのところ、他のものは多かれ少なかれ機能していますが、flume エージェントにはいくつかの問題があります。
これが私が取り組んでいるチュートリアルです。
チュートリアルに従ってすべてを実行すると、ターミナル出力は次のようになります。
16/02/05 17:19:33 INFO conf.FlumeConfiguration: Post-validation flume configuration contains configuration for agents: [shaman]
16/02/05 17:19:33 INFO node.AbstractConfigurationProvider: Creating channels
16/02/05 17:19:33 INFO channel.DefaultChannelFactory: Creating instance of channel in-mem_c1 type memory
16/02/05 17:19:33 INFO node.AbstractConfigurationProvider: Created channel in-mem_c1
16/02/05 17:19:33 INFO source.DefaultSourceFactory: Creating instance of source netcat_s1, type netcat
16/02/05 17:19:33 INFO node.AbstractConfigurationProvider: Channel in-mem_c1 connected to [netcat_s1]
16/02/05 17:19:33 INFO node.Application: Starting new configuration:{ sourceRunners:{netcat_s1=EventDrivenSourceRunner: { source:org.apache.flume.source.NetcatSource{name:netcat_s1,state:IDLE} }} sinkRunners:{} channels:{in-mem_c1=org.apache.flume.channel.MemoryChannel{name: in-mem_c1}} }
16/02/05 17:19:33 INFO node.Application: Starting Channel in-mem_c1
16/02/05 17:19:34 INFO instrumentation.MonitoredCounterGroup: Monitored counter group for type: CHANNEL, name: in-mem_c1: Successfully registered new MBean.
16/02/05 17:19:34 INFO instrumentation.MonitoredCounterGroup: Component type: CHANNEL, name: in-mem_c1 started
16/02/05 17:19:34 INFO node.Application: Starting Source netcat_s1
16/02/05 17:19:34 INFO source.NetcatSource: Source starting
16/02/05 17:19:34 INFO source.NetcatSource: Created
serverSocket:sun.nio.ch.ServerSocketChannelImpl[/127.0.0.1:44444]
そこから先はどうにもなりません。端末をシャットダウンするまで、このままです。
エージェントに telnet で接続しようとしましたが、メッセージが表示されません。
何がうまくいかなかったのですか？