2016-02-05 121 views
0

我有一個水槽的問題。我正在嘗試獲取大數據,因此我正在使用「傻瓜書」中的教程。到目前爲止,其他的東西或多或少有效,但是水槽代理存在一些問題。Flume Agent沒有收到數據但沒有錯誤

Here是我正在使用的教程。

當我按照教程做的一切,我的終端輸出將如下:

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代理但消息不會出現。

任何想法是什麼?

回答

0

在本教程中,它將數據放入HDFS中,請檢查您的HDFS目錄。