Looks like a config.parser issue in RollingFileSink.java or Configuration.java. Please open a Jira for. The error messages comes from the Preconditions check (Google Guava library) in RollingFileSink.java, indeed the variable for the directory is empty.
- Alex -- Alexander Alten-Lorenz http://mapredit.blogspot.com German Hadoop LinkedIn Group: http://goo.gl/N8pCF On May 21, 2012, at 3:50 PM, Guillaume Polaert wrote: > Thank you for the link. > I've created a empty directory /tmp/log (mkdir+chmod). > > Do I have to create other things ? > > -----Message d'origine----- > De : alo alt [mailto:[email protected]] > Envoyé : lundi 21 mai 2012 15:31 > À : [email protected] > Objet : Re: RollingFile Sink problems > > Hi, > > http://archive.cloudera.com/cdh4/cdh/4/flume-ng-1.1.0-cdh4.0.0b2/FlumeUserGuide.html#h.frlqql6vu68 > > Means, /tmp/log is empty or non existent, isn't it? > > - Alex > > -- > Alexander Alten-Lorenz > http://mapredit.blogspot.com > German Hadoop LinkedIn Group: http://goo.gl/N8pCF > > On May 21, 2012, at 3:03 PM, Guillaume Polaert wrote: > >> Hi everybody, >> >> I've problems with RollingFile sink. >> First, I'm seeking about the sink's properties. I've found two properties in >> RollingFileSink.java : rollInterval and directory. Are there anymore ? >> >> Then, I've this error when I'm running the node : >> >> . >> SINKS: {sink=ComponentConfiguration[sink] >> CONFIG: {directory=/tmp/log, type=file_roll} >> RUNNER: ComponentConfiguration[runner] >> CONFIG: {} >> >> >> , log-sink1=ComponentConfiguration[log-sink1] >> CONFIG: {type=logger, channel=ch1} >> RUNNER: ComponentConfiguration[runner] >> CONFIG: {} >> >> } >> . >> 2012-05-21 08:29:15,246 (conf-file-poller-0) [INFO - >> org.apache.flume.sink.DefaultSinkFactory.create(DefaultSinkFactory.jav >> a:69)] Creating instance of sink sink typefile_roll >> 2012-05-21 08:29:15,253 (conf-file-poller-0) [ERROR - >> org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:205)] >> Failed to load configuration data. Exception follows. >> java.lang.IllegalArgumentException: Directory may not be null >> at >> com.google.common.base.Preconditions.checkArgument(Preconditions.java:88) >> at >> org.apache.flume.sink.RollingFileSink.configure(RollingFileSink.java:74) >> at >> org.apache.flume.conf.Configurables.configure(Configurables.java:41) >> . >> >> Flume.conf >> >> # Define a memory channel called ch1 on agent1 >> agent1.channels.ch1.type = memory >> >> # Define an Avro source called avro-source1 on agent1 and tell it # to >> bind to 0.0.0.0:41414. Connect it to channel ch1. >> agent1.sources.avro-source1.channels = ch1 >> agent1.sources.avro-source1.type = avro >> agent1.sources.avro-source1.bind = 0.0.0.0 >> agent1.sources.avro-source1.port = 41414 >> >> # Define a logger sink that simply logs all events it receives # and >> connect it to the other end of the same channel. >> agent1.sinks.log-sink1.channel = ch1 >> agent1.sinks.log-sink1.type = logger >> agent1.sinks.sink.channel = ch1 >> agent1.sinks.sink.type = file_roll >> agent1.sinks.sink.directory=/tmp/log >> >> # Finally, now that we've defined all of our components, tell # agent1 >> which ones we want to activate. >> agent1.channels = ch1 >> agent1.sources = avro-source1 >> agent1.sinks = sink >> >> What is wrong ? I don't understand the problem. >> >> Guillaume >
