flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Juhani Connolly <juhani_conno...@cyberagent.co.jp>
Subject Re: Problems with HDFS Sink (file rolling)
Date Thu, 02 Aug 2012 02:00:11 GMT
This was fixed in one of the patches for 1.2. We have files separated by 
hour and have the interval set to a bit over an hour and everything is 
closed properly. I'm not entirely sure about what happens when you 
restart flume though.

On 08/01/2012 09:41 PM, Christian Schroer wrote:
> Hi,
> i have some trouble setting up the HDFS sink in Flume-NG (CDH3U4, 1.1.0):
> Here's my sink configuration:
> agent.sinks.hdfsSinkSMP.type = hdfs
> agent.sinks.hdfsSinkSMP.channel = memoryChannel
> agent.sinks.hdfsSinkSMP.hdfs.filePrefix = flumenode1
> agent.sinks.hdfsSinkSMP.hdfs.fileType = SequenceFile
> agent.sinks.hdfsSinkSMP.hdfs.codeC = gzip
> agent.sinks.hdfsSinkSMP.hdfs.rollCount = 0
> agent.sinks.hdfsSinkSMP.hdfs.batchSize = 1
> agent.sinks.hdfsSinkSMP.hdfs.rollInterval = 15
> agent.sinks.hdfsSinkSMP.hdfs.rollSize = 0
> agent.sinks.hdfsSinkSMP.hdfs.path = hdfs://namenode/user/hive/warehouse/someDatabase.db
> Events are genereated by a SyslogTcp source. We write the data into hive partions. This
works, it just keeps open a lot of .tmp files. I disabled event count and size based file
rolling, just enabled the interval to have the files closed after 15 seconds. But flume keeps
files open much longer than 15 seconds (sometimes for hours or even never closing them). Also
stopping flume keeps .tmp files in those directories. Sometimes it opens new files in partions
without having any data for those. Maybe I'm doing the file rolling completely wrong?
> Some hive jobs use 5 minutes old data, but if flume renames a file after job start, the
job fails. That's the reason why I want to close the files after 15 seconds. New files are
no problems.
> Anyone has an idea?
> Best regards,
> Christian

View raw message