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 A47CA17564 for ; Mon, 2 Feb 2015 19:20:55 +0000 (UTC) Received: (qmail 55699 invoked by uid 500); 2 Feb 2015 19:20:22 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 55639 invoked by uid 500); 2 Feb 2015 19:20:22 -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 55629 invoked by uid 99); 2 Feb 2015 19:20:22 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Feb 2015 19:20:22 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of hshreedharan@cloudera.com designates 209.85.216.54 as permitted sender) Received: from [209.85.216.54] (HELO mail-qa0-f54.google.com) (209.85.216.54) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Feb 2015 19:20:16 +0000 Received: by mail-qa0-f54.google.com with SMTP id w8so30616259qac.13 for ; Mon, 02 Feb 2015 11:19:11 -0800 (PST) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:date:mime-version:message-id:in-reply-to :references:from:to:cc:subject:content-type; bh=Vdh0OSQ1zhXf6Wx0gigEf6zUnlF8Z9WX0xj2tHMgfCs=; b=NnTvFeqtterKTtHtWCZK8fNzZj2fpoJklPsCT5b5xSqsPkllH4ihoza6I0BeDQnt8o mcSLu3B6ST6gjftSZ13DfS3VJiGVwxQv2NMJpRf9/tWbVruokXHR/UsE/rgPg5z6ICyi ab1mbJ3hedP/wyk0Qo23vy0KnUWBQEHNaSv5fnXBTjDwJ8F9LsJrOOcak0FzEsS7puyb rTC7GGDDZWo08llB6IJdQRXPlTVrl1YdRlj+CdlxI4cgrOQAzhQ2IuPsYvWNskoys6w9 sMegGMc7rUuPKzAV+sXJXYCr9YnIYi31+Rq+VWn3sS7O9pgd9tYubNOqJyZSvQMGQVq1 NS6g== X-Gm-Message-State: ALoCoQmqggEucUj8zdBds21XRXm9E9SVJyXSUYGoeI6VYIiRxs8t8AtkmKYgj8EUtgts0wY3g0DZ X-Received: by 10.140.20.226 with SMTP id 89mr2696492qgj.16.1422904751066; Mon, 02 Feb 2015 11:19:11 -0800 (PST) Received: from hedwig-6.prd.orcali.com (ec2-54-85-253-252.compute-1.amazonaws.com. [54.85.253.252]) by mx.google.com with ESMTPSA id y5sm19108501qah.38.2015.02.02.11.19.10 for (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Mon, 02 Feb 2015 11:19:10 -0800 (PST) Date: Mon, 02 Feb 2015 11:19:10 -0800 (PST) X-Google-Original-Date: Mon, 02 Feb 2015 19:19:09 GMT MIME-Version: 1.0 X-Mailer: Nodemailer (0.5.0; +http://www.nodemailer.com/) Message-Id: <1422904749833.3bc03876@Nodemailer> In-Reply-To: References: X-Orchestra-Oid: BB85E160-A7DC-4125-B585-9048545D9C49 X-Orchestra-Sig: 55e2bdf761dff5d85b540eba82e293117651be85 X-Orchestra-Thrid: TEB56D109-7104-46FE-9747-57A7D6EE5D69_1492022069015730619 X-Orchestra-Thrid-Sig: 9335a35ab5553d66edc2c20bb9a67b42d29c3dca X-Orchestra-Account: 1465dd56cd09c71fa31519ad4317e42b42e8d6cd From: "Hari Shreedharan" To: user@flume.apache.org Cc: user@flume.apache.org Subject: Re: Delete individual message from queue Content-Type: multipart/alternative; boundary="----Nodemailer-0.5.0-?=_1-1422904750383" X-Virus-Checked: Checked by ClamAV on apache.org ------Nodemailer-0.5.0-?=_1-1422904750383 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable Currently, no - there is no such tool, but this is a request that has come = up time and again. Can you file a jira for this=3F If someone has time, = they=E2=80=99d probably pick it up Thanks,=C2=A0Hari On Mon, Feb 2, 2015 at 10:52 AM, Charles McLaughlin wrote: > Hello, > We had a situation where one of our Flume agents got stuck on a message = due > to unexpected format. To get things moving again, I stopped the Flume > agent, moved the file backed channel data out of the way and re-started = the > Flume agent. I'd like to pop the bad message from the queue data on > disk... are there any tools or recommended ways to do this=3F > Thanks, > Charles ------Nodemailer-0.5.0-?=_1-1422904750383 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: quoted-printable
Currently, no - there is no such= tool, but this is a request that has come up time and again. Can you file = a jira for this=3F If someone has time, they=E2=80=99d probably pick it = up

Thanks,=C2=A0
Hari


On Mon, Feb 2, 2015 at 10:52 AM= , Charles McLaughlin <charles@nextdoor.com>= wrote:

Hello,

We had a situation where one of our Flume agents got stuck on a = message due to unexpected format.=C2=A0 To get things moving again, I = stopped the Flume agent, moved the file backed channel data out of the way = and re-started the Flume agent.=C2=A0 I'd like to pop the bad message from = the queue data on disk... are there any tools or recommended ways to do = this=3F

Thanks,
Charles

------Nodemailer-0.5.0-?=_1-1422904750383--