From flume-user-return-756-apmail-incubator-flume-user-archive=incubator.apache.org@incubator.apache.org Fri Mar 2 18:04:29 2012 Return-Path: X-Original-To: apmail-incubator-flume-user-archive@minotaur.apache.org Delivered-To: apmail-incubator-flume-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 14A08973E for ; Fri, 2 Mar 2012 18:04:29 +0000 (UTC) Received: (qmail 43738 invoked by uid 500); 2 Mar 2012 18:04:28 -0000 Delivered-To: apmail-incubator-flume-user-archive@incubator.apache.org Received: (qmail 43676 invoked by uid 500); 2 Mar 2012 18:04:28 -0000 Mailing-List: contact flume-user-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: flume-user@incubator.apache.org Delivered-To: mailing list flume-user@incubator.apache.org Received: (qmail 43667 invoked by uid 99); 2 Mar 2012 18:04:28 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 02 Mar 2012 18:04:28 +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 kowshik@gmail.com designates 209.85.210.47 as permitted sender) Received: from [209.85.210.47] (HELO mail-pz0-f47.google.com) (209.85.210.47) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 02 Mar 2012 18:04:22 +0000 Received: by dado14 with SMTP id o14so2001271dad.6 for ; Fri, 02 Mar 2012 10:04:02 -0800 (PST) Received-SPF: pass (google.com: domain of kowshik@gmail.com designates 10.68.125.195 as permitted sender) client-ip=10.68.125.195; Authentication-Results: mr.google.com; spf=pass (google.com: domain of kowshik@gmail.com designates 10.68.125.195 as permitted sender) smtp.mail=kowshik@gmail.com; dkim=pass header.i=kowshik@gmail.com Received: from mr.google.com ([10.68.125.195]) by 10.68.125.195 with SMTP id ms3mr19037489pbb.62.1330711442227 (num_hops = 1); Fri, 02 Mar 2012 10:04:02 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:cc:content-type; bh=XVVmjZa2rjShbaucOgJEhQv6k9e7FxtadnKGT+Pkh9w=; b=it8gBPk31yTTP8LBTUoY7OWj0Xw9QeMCZlegFIAvD9WJP9qTnU748J+AaBPl+fT3Lv QyQdVs3ICjLOqMzdlFClp+0BRSJLMRpMdInEgi3U5srk2mZdN6ffe4lTMTih38ExliHa L3f7C2Ct3abKJZwxX+TyY+PVpPh/ivLTOepcFLBl5G9bpmIu3je6gcGhdPf/mJCPycy1 R9kxb1A3MLLRm8ntTIHuXpmnITYDkaNYONG3FWUDlQ1CLurlg1umTK1nEoPUzebb8FnX XwXGnaH96XO4vzzXunmjk6FsWdS220yZ9eAHtxnGuWkpLkR7HDnDEkpxXEC9ZztntoEN hRkA== MIME-Version: 1.0 Received: by 10.68.125.195 with SMTP id ms3mr15893042pbb.62.1330711442145; Fri, 02 Mar 2012 10:04:02 -0800 (PST) Received: by 10.142.178.11 with HTTP; Fri, 2 Mar 2012 10:04:02 -0800 (PST) Date: Fri, 2 Mar 2012 10:04:02 -0800 Message-ID: Subject: Accessing Flume Shell via RPC From: Kowshik Prakasam To: flume-user@incubator.apache.org Cc: Chandra Krintz , Navraj Chohan , Chris Bunch Content-Type: multipart/alternative; boundary=047d7b2e4cdccec23e04ba466604 X-Virus-Checked: Checked by ClamAV on apache.org --047d7b2e4cdccec23e04ba466604 Content-Type: text/plain; charset=ISO-8859-1 Hi all, >From a flume master, I'm making a bulk of config changes to flume agents running in a cluster. Firing a flume shell command every time for each change is a very slow process. Is there a way that I can programatically connect to the flume master to issue RPC calls that can mimic the flume shell? -Kowshik --047d7b2e4cdccec23e04ba466604 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi all,

From a flume master, I'm making a bulk of co= nfig changes=A0to flume agents=A0running in
a cluster. Firing a f= lume shell command every time for each change=A0is=A0a very slow process.
Is there a way that I can programatically connect to the flume master = to issue RPC
calls that can mimic the flume shell?

-Kowshik
--047d7b2e4cdccec23e04ba466604--