Thanks David.
On Thu, Oct 24, 2013 at 2:47 PM, David Sinclair <
dsincl...@chariotsolutions.com> wrote:
> You could do that or add the TimestampInterceptor to your source as well.
>
>
> On Thu, Oct 24, 2013 at 5:16 AM, Deepak Subhramanian <
> deepak.subhraman...@gmail.com> wrote:
>
>> I am using
You could do that or add the TimestampInterceptor to your source as well.
On Thu, Oct 24, 2013 at 5:16 AM, Deepak Subhramanian <
deepak.subhraman...@gmail.com> wrote:
> I am using a SimpleHTTPEventHandler which implements HTTPSourceHandler
> which reads a log message from HTTP Request and create
I am using a SimpleHTTPEventHandler which implements HTTPSourceHandler
which reads a log message from HTTP Request and create a Flume event. May
be I have to add the header to the event with the timestamp.
String message = (String)request.getParameter("log");
//LOG.info(message );
LOG.inf
The sink is dependent on a header with the key "timestamp" being present in
the event for this to work. What source are you using?
On Wed, Oct 23, 2013 at 11:25 AM, Deepak Subhramanian <
deepak.subhraman...@gmail.com> wrote:
> Hi ,
>
> I am trying to store my logs in folders named with date for
Hi ,
I am trying to store my logs in folders named with date for my file_roll
and hdfssink. For some reason when I pass %d%m%Y in the sink directory it
is not working . Any thoughts .
My Flume source is a simple HTTP Handler extended from HTTPSourceHandler
tier1.sinks.filesink1.type = file_roll
