Return-Path: X-Original-To: apmail-nifi-dev-archive@minotaur.apache.org Delivered-To: apmail-nifi-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0090619582 for ; Thu, 21 Apr 2016 12:49:07 +0000 (UTC) Received: (qmail 39242 invoked by uid 500); 21 Apr 2016 12:49:06 -0000 Delivered-To: apmail-nifi-dev-archive@nifi.apache.org Received: (qmail 39197 invoked by uid 500); 21 Apr 2016 12:49:06 -0000 Mailing-List: contact dev-help@nifi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@nifi.apache.org Delivered-To: mailing list dev@nifi.apache.org Received: (qmail 39185 invoked by uid 99); 21 Apr 2016 12:49:06 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Apr 2016 12:49:06 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 21478C05EF for ; Thu, 21 Apr 2016 12:49:06 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.179 X-Spam-Level: * X-Spam-Status: No, score=1.179 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx2-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id Gx72ozqDXqS2 for ; Thu, 21 Apr 2016 12:49:04 +0000 (UTC) Received: from mail-wm0-f51.google.com (mail-wm0-f51.google.com [74.125.82.51]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with ESMTPS id 8097D5F253 for ; Thu, 21 Apr 2016 12:49:03 +0000 (UTC) Received: by mail-wm0-f51.google.com with SMTP id u206so130780916wme.1 for ; Thu, 21 Apr 2016 05:49:03 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=KsE7dwuJIaS/NHjl3K82MqAc5tJh4Rrk7CJJAY6Q1XA=; b=FeYozhPrMixqUcaoLI6HKJlw0xSo48wPGKZ/5lupGalZJCX8hDfEa9WW+W7URqKc0u mS1rAZtTBLPRyWtY/WcDf6giPAJ5SFIDYebY3JGxqaAbsfUPOj8X17MP+DA4RzBRd+1A ClFLc/9YVZZu/HIw9+iNMMVR/oLg5ziTN+WH8dUt8ZckQVG8DpJ/1H9792+X9fLZbJg+ C9P/T8FuG4M+n3JCzrLU4n8rKZ73gSw2pRkgI4+rB8Op4yPDRWnYuU4AbfMuzCTrxrHs Ty9ZVl6M8l7k/wEi4wWLFx90DHy7PcqWBJyrJ3PTT3TMRWlBcQcqCMJC0Na6lLOc91uQ NWsg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=KsE7dwuJIaS/NHjl3K82MqAc5tJh4Rrk7CJJAY6Q1XA=; b=EoRKQTCYXhQ0SoBIyZgoU1x0wNjvdstoa3DvTNPli2jshwlwt3Agpk3R6TvEV1MKNS 0lCLvT6CZMWKQXIKGekRbqEJFZcQWVbXMK0iRARKJhg30Lb8crkl2s/q7N0QBC3qW7JR Nkg69WC1a7jscCUVkgQa4JaqxEcQ0dsuoQskLy8E2J1ywfkguziD2ggEayyHwdtxayfy +mFsqvEL5ilKgQI2EcihDwC2z6eurYGgVo1UMbd0KhgIH0mRydT1gvw8rU+6AWqhNK85 0kZalNASVGMGNqJpxUPZ3C+9VK5ma0zv46QiqXvxGdp1NJu9a7jpnGH1gBkaGJdvpQx9 76Eg== X-Gm-Message-State: AOPr4FW1jYdZcttU4YdowX9cZeyVZlv4AAKY2cIRIsUeDyyv1lxVSHRrAyugoYXVWopIBghb6ytBThftffLmcA== X-Received: by 10.28.47.208 with SMTP id v199mr12338984wmv.56.1461242942508; Thu, 21 Apr 2016 05:49:02 -0700 (PDT) MIME-Version: 1.0 Received: by 10.28.113.196 with HTTP; Thu, 21 Apr 2016 05:48:23 -0700 (PDT) In-Reply-To: <5831f062a8ab4dcfa8db420e4d78d76b@MBX1.impetus.co.in> References: <35580C13-6A96-4C11-9E56-22C03847E6CA@hortonworks.com> <7A6003DD-BDE4-4809-A35B-EB1A92CE58A9@hortonworks.com> <9a993e1125e747eaa6d5dee211a69eab@MBX1.impetus.co.in> <5831f062a8ab4dcfa8db420e4d78d76b@MBX1.impetus.co.in> From: Pierre Villard Date: Thu, 21 Apr 2016 14:48:23 +0200 Message-ID: Subject: Re: Reg: Tailing a remote file To: dev Content-Type: multipart/alternative; boundary=001a114975b284e0dd0530fe223f --001a114975b284e0dd0530fe223f Content-Type: text/plain; charset=UTF-8 Sourav, If what is behind your '*' has some format logic (like dates), you could try using expression language. Otherwise there is an open JIRA for this: NIFI-1170. 2016-04-21 14:42 GMT+02:00 Sourav Gulati : > Simon, > > I see an issue with tail processor . > > I have to give the exact name of the file to tail. I can give something > like /home/user/abc*.log > > Is there anyway I can do this? > > Regards, > Sourav Gulati > > -----Original Message----- > From: Simon Ball [mailto:sball@hortonworks.com] > Sent: Thursday, April 21, 2016 3:40 PM > To: dev@nifi.apache.org > Subject: Re: Reg: Tailing a remote file > > If you're using a rolling file name pattern you will want to tail the > current log file, and essentially ignore the rolled history, unless you > need to represses or miss data. > > TailFile is a local processor, so you would run a nifi agent on the box > that has the files on, use tail file -> remote process group -> input port > on core nifi instance -> wherever your data is going next. > > The local/remote setting comes up when clustering nifi and using something > like an NFS mount to get to the files being tailed, which is a different > way of doing this. The remote will lead to state about where you've gotten > to being stored differently to support the cluster continuing to tail from > alternative nifi cluster nodes. > > Simon > > > > On 21 Apr 2016, at 11:38, Sourav Gulati > wrote: > > > > Hi Simon/Team. > > > > Please provide some good example of tail processor. > > > > I need some example for " Rolling Filename Pattern". > > > > Also, as per my knowledge TailFile processor is used for tailing local > file then what does location attribute signifies, if I set it to remote. > > > > Regards, > > Sourav Gulati > > > > -----Original Message----- > > From: Simon Ball [mailto:sball@hortonworks.com] > > Sent: Wednesday, April 20, 2016 2:27 PM > > To: dev@nifi.apache.org > > Subject: Re: Reg: Tailing a remote file > > > > Site-to-site is in pretty much every version of nifi released under > apache. > > > >> On 20 Apr 2016, at 10:48, Sourav Gulati > wrote: > >> > >> Thanks Simon. Which version of Nifi support site to site? > >> > >> Regards, > >> Sourav Gulati > >> > >> -----Original Message----- > >> From: Simon Ball [mailto:sball@hortonworks.com] > >> Sent: Wednesday, April 20, 2016 1:28 PM > >> To: dev@nifi.apache.org > >> Subject: Re: Reg: Tailing a remote file > >> > >> The best way to do this would be to run a nifi agent on the remote > system, using the TailFile processor, and then use site-to-site to get that > into your core nifi. > >> > >> Simon > >> > >> > >>> On 20 Apr 2016, at 09:49, Sourav Gulati > wrote: > >>> > >>> Hi Team, > >>> > >>> We want to process logs from a file which is getting updated > continuously on remote system. > >>> > >>> What is the best way to do that in NiFi? > >>> > >>> Regards, > >>> Sourav Gulati > >>> > >>> > >>> ________________________________ > >>> > >>> > >>> > >>> > >>> > >>> > >>> NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. > >> > >> ________________________________ > >> > >> > >> > >> > >> > >> > >> NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. > > > > > > ________________________________ > > > > > > > > > > > > > > NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. > > > > ________________________________ > > > > > > > NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. > --001a114975b284e0dd0530fe223f--