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 2EB55173F2 for ; Sun, 19 Oct 2014 08:38:59 +0000 (UTC) Received: (qmail 43143 invoked by uid 500); 19 Oct 2014 08:38:58 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 43081 invoked by uid 500); 19 Oct 2014 08:38:58 -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 43071 invoked by uid 99); 19 Oct 2014 08:38:58 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 19 Oct 2014 08:38:58 +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 (athena.apache.org: domain of terreyshih@gmail.com designates 209.85.192.173 as permitted sender) Received: from [209.85.192.173] (HELO mail-pd0-f173.google.com) (209.85.192.173) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 19 Oct 2014 08:38:51 +0000 Received: by mail-pd0-f173.google.com with SMTP id g10so3159479pdj.4 for ; Sun, 19 Oct 2014 01:38:31 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=content-type:mime-version:subject:from:in-reply-to:date :content-transfer-encoding:message-id:references:to; bh=VaO4DqYvbzEpTjknrH4sI6+vn+zLCUtI/VOncl6NYbM=; b=o8xa0PMQuLIqlyVlW4RNS7YpQOPMqGZ+wjdfGo9sBArFI8wALEBfxc0tOoSXnZymou paEbZ/Nz1mOOj8DR0ARzc7pGSXPpBM/+WfUQAypgr5Nc1ElgHgyxClB4tuMJ6I1AVoGv GxDdfRJcgmEDw88dKk5K1oEg2DqcmYjn5D+iLrbEhIovI8iVEpTUSacanz/3Df7ThxaC ncqnrOwPK08jJx3FZKdlQwPuW+KdKb2ijkT6yLCeBeQhJVd86VQ9uLsj/FA6Tyuf7x3R Plt7Td0zSgHLqbQJWeeYzgn8doOSHs1TfSja6XxroxK+iJelFURWd2G/EcEm6DETdfJe V9hw== X-Received: by 10.68.218.162 with SMTP id ph2mr20169157pbc.19.1413707911505; Sun, 19 Oct 2014 01:38:31 -0700 (PDT) Received: from garys-mbp.attlocal.net (75-54-228-9.lightspeed.sntcca.sbcglobal.net. [75.54.228.9]) by mx.google.com with ESMTPSA id zw1sm5952048pbb.82.2014.10.19.01.38.30 for (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Sun, 19 Oct 2014 01:38:31 -0700 (PDT) Content-Type: text/plain; charset=us-ascii Mime-Version: 1.0 (Mac OS X Mail 8.0 \(1990.1\)) Subject: Re: flume avro event overflow ? From: terreyshih In-Reply-To: <3FE0B617-ED05-468D-A920-3AF5EE0A11B9@gmail.com> Date: Sun, 19 Oct 2014 01:38:29 -0700 Content-Transfer-Encoding: quoted-printable Message-Id: <828FBF37-7433-40F3-9EF9-9F9B19C926E3@gmail.com> References: <3FE0B617-ED05-468D-A920-3AF5EE0A11B9@gmail.com> To: user@flume.apache.org X-Mailer: Apple Mail (2.1990.1) X-Virus-Checked: Checked by ClamAV on apache.org In other words, I would like to explicitly drop the events if the = channel/event queue if full. thx > On Oct 18, 2014, at 11:42 PM, terreyshih wrote: >=20 > Hi, >=20 > If I have a upstream agent duplicating the event to two channels and = subsequently to two downstream sinks. If one of the downstream sinks = for some reason can not process the events fast enough and the event = overflows back over the buffer limit of the upstream agent, would it = cause any issues for the other channel since the events are duplicated ? >=20 > In general, what happens if the downstream agent is not able to handle = the speed of the upstream agent sending the events ? I have seen = exceptions that says unable to send events or memory channel commit = issues. =20 >=20 > However, the flume agent does not seem to handle that gracefully and = the whole agent just stops processing the events for all channels, even = for the channels that can keep up with events. >=20 > What if I separate the two channels into two different agents, would = that solve the problem. >=20 > Can upstream flume agent not just drop the events when one of the its = sinks or downstream agents cannot catch up ? >=20 > thx