I am new to Flume and we are planning to usse Flume to log collection
and aggregation.

I am trying to link a node to a collector and trying to send some
console o/p to the collector. I configured the node

host: console | agentSink("localhost",35863);
c1: collectorSource(35863) | console;

I started the flume node using the following command

flume node_nowatch -n c1


I am gettting the follwoing error on the collector side. ere 35863 is
the port to which my collector daemon is hosted

2011-12-28 11:40:46,874 (logicalNode collect-28) [INFO -
com.cloudera.flume.handlers.thrift.ThriftEventSource.open(ThriftEventSource.java:
148)] Starting blocking thread pool server on port 35863...
2011-12-28 11:40:46,875 (logicalNode collect-28) [ERROR -
org.apache.thrift.server.TSaneThreadPoolServer.start(TSaneThreadPoolServer.java:
165)] Error occurred during listening.
org.apache.thrift.transport.TTransportException: Could not create
ServerSocket on address 0.0.0.0/0.0.0.0:35863.
      at
org.apache.thrift.transport.TSaneServerSocket.bind(TSaneServerSocket.java:
110)
      at
org.apache.thrift.transport.TSaneServerSocket.listen(TSaneServerSocket.java:
116)
      at
org.apache.thrift.server.TSaneThreadPoolServer.start(TSaneThreadPoolServer.java:
162)
      at
com.cloudera.flume.handlers.thrift.ThriftEventSource.open(ThriftEventSource.java:
151)
      at
com.cloudera.flume.collector.CollectorSource.open(CollectorSource.java:
67)
      at com.cloudera.flume.core.connector.DirectDriver
$PumperThread.run(DirectDriver.java:87)


Please help me in finding the solution to this problem

Reply via email to