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代理但消息不會出現。
任何想法是什麼?