incubator-flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aaron morton <aa...@thelastpickle.com>
Subject problem with the demo project
Date Fri, 12 Aug 2011 04:52:31 GMT
I'm using the 0.9.4 tar distro and running through the docs, when I got up to this point http://archive.cloudera.com/cdh/3/flume/UserGuide/index.html#_tiering_flume_nodes_agents_and_collectors

And tried to use this config (through the web console) 

10.0.1.150 : console | agentSink("localhost",35853) ;
collector : collectorSource(35853) | console ;

There was a big bang….

com.cloudera.flume.conf.FlumeSpecException: Parser error: unexpected 'collector' at position
0 line 2: '10.0.1.150 : console | agentSink("localhost",35853) ;
collector : collectorSource(35853) | console ;'
        at com.cloudera.flume.conf.FlumeSpecGen.generate(FlumeSpecGen.java:278)
        at com.cloudera.flume.master.MultiConfigCommand$1.exec(MultiConfigCommand.java:77)
        at com.cloudera.flume.master.CommandManager.exec(CommandManager.java:266)
        at com.cloudera.flume.master.CommandManager.handleCommand(CommandManager.java:205)
        at com.cloudera.flume.master.CommandManager$ExecThread.run(CommandManager.java:236)

My work around was to change the collector flume node name from "collector" to "coll" and
this then worked as a config

10.0.1.150 : console | agentSink("localhost",35853) ;
coll : collectorSource(35853) | console ;

Is collector a  token in the Antlr grammar ? 

Cheers
  
-----------------
Aaron Morton
Freelance Cassandra Developer
@aaronmorton
http://www.thelastpickle.com


Mime
View raw message