Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id AB07110A1F for ; Thu, 23 Jan 2014 03:10:27 +0000 (UTC) Received: (qmail 23823 invoked by uid 500); 23 Jan 2014 03:10:26 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 23250 invoked by uid 500); 23 Jan 2014 03:10:15 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 23225 invoked by uid 99); 23 Jan 2014 03:10:12 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Jan 2014 03:10:12 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy includes SPF record at spf.trusted-forwarder.org) Received: from [208.65.144.66] (HELO p01c11o143.mxlogic.net) (208.65.144.66) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Jan 2014 03:10:04 +0000 Received: from unknown [202.54.41.43] (EHLO PUNINMSHTCAS01.puneodc.lntinfotech.com) by p01c11o143.mxlogic.net(mxl_mta-7.2.2-0) with ESMTP id 7f780e25.2b724ae2a940.88943.00-555.239305.p01c11o143.mxlogic.net (envelope-from ); Wed, 22 Jan 2014 20:09:43 -0700 (MST) X-MXL-Hash: 52e087f73a73538e-5aa627a014caf791ace102fa1332d8d0cee64456 Received: from unknown [202.54.41.43] (EHLO PUNINMSHTCAS01.puneodc.lntinfotech.com) by p01c11o143.mxlogic.net(mxl_mta-7.2.2-0) over TLS secured channel with ESMTP id 3f780e25.0.88930.00-243.239263.p01c11o143.mxlogic.net (envelope-from ); Wed, 22 Jan 2014 20:09:40 -0700 (MST) X-MXL-Hash: 52e087f461a599d1-3fae5c5474c6c163d576587349826f0be5e448d6 Received: from puninmsmbx01.puneodc.lntinfotech.com ([169.254.1.126]) by PUNINMSHTCAS01.puneodc.lntinfotech.com ([172.20.8.112]) with mapi; Thu, 23 Jan 2014 08:39:36 +0530 From: Chhaya Vishwakarma To: Wolfgang Hoschek CC: "user@flume.apache.org" Date: Thu, 23 Jan 2014 08:38:21 +0530 Subject: RE: flume agent not starting Thread-Topic: flume agent not starting Thread-Index: Ac8XfmwHzQTHvyyWSryTTxBEVrn9ygAadv+A Message-ID: <969B118F8FF0104281DFF098C3347540576246EB7E@PUNINMSMBX01.puneodc.lntinfotech.com> References: <969B118F8FF0104281DFF098C33475405476B2589C@PUNINMSMBX01.puneodc.lntinfotech.com> <7D3C89B5-43ED-4E7F-B62C-60E0F72A264D@cloudera.com> <969B118F8FF0104281DFF098C3347540576246E7B0@PUNINMSMBX01.puneodc.lntinfotech.com> <969B118F8FF0104281DFF098C3347540576246E8D3@PUNINMSMBX01.puneodc.lntinfotech.com> In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: acceptlanguage: en-US Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-AnalysisOut: [v=2.0 cv=X4jl3hve c=1 sm=1 a=FLLpPgYZspyZ4nN2hYyR9A==:17 a] X-AnalysisOut: [=MHmriYiyTdgA:10 a=BLceEmwcHowA:10 a=kj9zAlcOel0A:10 a=tP0] X-AnalysisOut: [R5P8-AAAA:8 a=24K5aGlSWT4A:10 a=IFTmCX7IAAAA:8 a=mV9VRH-2A] X-AnalysisOut: [AAA:8 a=6OBm21jnQwVawfNKlfAA:9 a=CjuIK1q_8ugA:10 a=dbG880Y] X-AnalysisOut: [OAjkA:10 a=l9sy2tmZEXIA:10 a=Ks6EIIfpuJ0gSUu2:21 a=uI7VmOr] X-AnalysisOut: [obWn5otto:21] X-Spam: [F=0.2000000000; CM=0.500; MH=0.500(2014012224); S=0.200(2010122901)] X-MAIL-FROM: X-SOURCE-IP: [202.54.41.43] X-Virus-Checked: Checked by ClamAV on apache.org Hi, I want multiple line as one flume event=20 Regards, Chhaya Vishwakarma -----Original Message----- From: Wolfgang Hoschek [mailto:whoschek@cloudera.com]=20 Sent: Wednesday, January 22, 2014 8:00 PM To: Chhaya Vishwakarma Cc: user@flume.apache.org Subject: Re: flume agent not starting ExecSource always spits out one flume event per line, no matter what comman= d is executed. On Jan 22, 2014, at 9:09 AM, Chhaya Vishwakarma wrote: > Hi, >=20 > Is my interceptor configuration correct? Or there is some problem with th= at ? > Can someone guide me in this > Instead of tail I am using CAT now but same error its giving >=20 > Regards, > Chhaya Vishwakarma >=20 >=20 >=20 > -----Original Message----- > From: Chhaya Vishwakarma [mailto:Chhaya.Vishwakarma@lntinfotech.com] > Sent: Wednesday, January 22, 2014 10:20 AM > To: user@flume.apache.org > Subject: RE: flume agent not starting >=20 > Hi , >=20 > What i should use then for interceptor to work shall I use CAT ?? >=20 > -----Original Message----- > From: Wolfgang Hoschek [mailto:whoschek@cloudera.com] > Sent: Tuesday, January 21, 2014 6:30 PM > To: user@flume.apache.org > Subject: Re: flume agent not starting >=20 > 'tail' with exec source spits out one flume event per line into the inter= ceptor. But readMultiLine expects multiple lines per event, not one line pe= r event. In other words, by the time the data arrives in the interceptor it= 's already too late for readMultiLine to make sense. >=20 > Wolfgang. >=20 >=20 > On Jan 17, 2014, at 2:42 PM, Chhaya Vishwakarma wrote: >=20 >> Hi, >>=20 >> Agent is starting I am using morphline interceptor to parse events >>=20 >> Below is my morphline configuration >>=20 >> morphlines : [ >> { >> id : morphline1 >>=20 >> commands : [ >> { >> readMultiLine { >> regex : "Started session*" >> what : next >> charset : UTF-8 >> } >> } >> ] >> } >> ] >>=20 >> This is my flume configuration file >>=20 >> host1.sources =3D src1 >> host1.sinks =3D sink1 >> host1.channels =3D ch1 >>=20 >> host1.sources.src1.type =3D exec >> host1.sources.src1.command =3D tail -F >> /home/user/apache-flume-1.4.0-bin/try.log >> host1.sources.src1.channels =3D ch1 >> host1.sources.src1.restart =3D true >> #host1.sources.src1.batchsize=3D10 >>=20 >> host1.sources.src1.interceptors =3D morphlineinterceptor=20 >> host1.sources.src1.interceptors.morphlineinterceptor.type =3D=20 >> org.apache.flume.sink.solr.morphline.MorphlineInterceptor$Builder >> host1.sources.src1.interceptors.morphlineinterceptor.morphlineFile =3D=20 >> /home/user/apache-flume-1.4.0-bin/morphline.conf >>=20 >> host1.sinks.sink1.type =3D file_roll >> host1.sinks.sink1.channel =3D ch1 >> host1.sinks.sink1.sink.directory =3D /home/user/apache-flume-1.4.0-bin=20 >> host1.sinks.sink1.sink.serializer=3D TEXT >> host1.sinks.sink1.sink.rollInterval=3D0 >>=20 >> host1.channels.ch1.capacity=3D1000 >> host1.channels.ch1.transactionCapacity=3D100 >>=20 >> host1.channels.ch1.type=3Dmemory >>=20 >> input file content >>=20 >> Started session >> a >> b >> c >> Started session >> c >> d >> e >> Started session >>=20 >> But in /home/user/apache-flume-1.4.0-bin I can see a file named >> 1389960784130-1 but it's not showing any content. I can see only new=20 >> line characters in output file >>=20 >> Regards, >> Chhaya Vishwakarma >>=20 >>=20 >> The contents of this e-mail and any attachment(s) may contain confidenti= al or privileged information for the intended recipient(s). Unintended reci= pients are prohibited from taking action on the basis of information in thi= s e-mail and using or disseminating the information, and must notify the se= nder and delete it from their system. L&T Infotech will not accept responsi= bility or liability for the accuracy or completeness of, or the presence of= any virus or disabling code in this e-mail" >=20